Как сделать чтобы один поток подсчитывал количество строк в одном файле, второй во втором и т.д.?
public class ThreadMain {
static ArrayList<File> FilesFind = new ArrayList<>();
public static void main(String[] args) {
String mask;
Scanner DIR_NAME = new Scanner(System.in);
Scanner MASK_NAME = new Scanner(System.in);
System.out.println("Введите директорию :");
getFilesList(DIR_NAME.nextLine());
System.out.println("Введите маску для поиска");
mask = MASK_NAME.nextLine();
System.out.println("Результат поиска :");
ExecutorService executor = Executors.newFixedThreadPool(10);
for (int i = 0; i < 10; i++) {
Runnable worker = new ThreadPools(FilesFind, mask);
executor.execute(worker);
}
executor.shutdown();
while (!executor.isTerminated()) {
}
System.out.println("Потоки закончили работу");
}
public static void getFilesList(String nameDirectory) {
File f = new File(nameDirectory);
for (File str : f.listFiles()) {
if (str.isFile()) {
FilesFind.add(str);
} else if (str.isDirectory()) {
getFilesList(str.getAbsolutePath());
}
}
}
}
Класс ThreadPools
:
class ThreadPools implements Runnable {
private ArrayList<File> FilesFindThread;
private String maskThread;
private String search;
ThreadPools(ArrayList<File> FilesFind, String mask) {
this.FilesFindThread = FilesFind;
this.maskThread = mask;
}
@Override
public void run() {
CountStrings();
}
public void CountStrings() {
for (File fill : FilesFindThread) {
try {
BufferedReader reader = new BufferedReader(new FileReader(fill));
int count = 0;
while ((search = reader.readLine()) != null) {
if (search.contains(maskThread) && !search.isEmpty()) {
count++;
}
}
reader.close();
System.out.println(Thread.currentThread().getName() + ":" + "Name files :" + fill.getName() + " ---- > " + count);
} catch (java.io.IOException e) {
System.out.println(e);
}
}
}
}