I want to read elements from array and display progress of reading as parallel process reading.
I have two interal classes:
public class NumbersCounter {
int totalCountOfLines;
int currentCountOfLines = 1;
public NumbersCounter() throws FileNotFoundException, IOException {
new Read();
new Progress();
}
public static void main(String[] args) {
try {
new NumbersCounter();
} catch (FileNotFoundException ex) {
Logger.getLogger(NumbersCounter.class.getName()).log(Level.SEVERE, null, ex);
} catch (IOException ex) {
Logger.getLogger(NumbersCounter.class.getName()).log(Level.SEVERE, null, ex);
}
}
class Progress extends Thread {
public Progress() {
start();
}
@Override
public void run() {
synchronized(new Object()) {
while (currentCountOfLines <= totalCountOfLines) {
System.out.println(currentCountOfLines / totalCountOfLines * 100 + "%");
Thread.yield();
}
}
}}
class Read extends Thread {
private FileHandler fh = new FileHandler("ololo.txt");
private String[] lines;
public Read() throws FileNotFoundException, IOException {
this.lines = fh.readFromFile();
start();
}
@Override
public void run() {
totalCountOfLines = this.lines.length;
if (totalCountOfLines > 0) {
synchronized(new Object()) {
for (String line : lines) {
currentCountOfLines++;
Thread.yield();
}
}
} else {
totalCountOfLines = 0;
}
}
}
}
When first step of Read Thread is executed, I need to give executing to Progress thread, and then for Read, and then for Progress.