如何使用循环中生成的线程进行多线程处理？

Question

所以我正在编写代码，它将解析文件夹中的多个文本文件，收集它们的信息，并将这些信息保存在两个静态列表实例变量中。信息存放的顺序并不重要，因为我最终将对其进行排序。但由于某些原因，增加线程数不会影响速度。这是我的run方法和主方法中利用多线程的部分。

public void run() {
    parseFiles();
}
public static void main(String[] args) {
    while (filesLeft != 0) {
        Thread t = new Thread(new fileParser());
        t.start();
        try {
            t.join();
        }
        catch (InterruptedException e) {
            System.out.println("error.");
        }
}

如果需要额外的信息，我基本上有一个静态实例变量作为我需要浏览的文件的数组，还有一个常量是线程数（为了测试目的手动更改）。如果我有4个线程和8个文件，每个对parseFiles的调用都会经过数组的下两个文件，索引由一个静态实例变量监控。如果我有，比如说，4个线程和9个文件，第一个线程解析3个文件，接下来的解析2，用一个类似于filesToParse=Math.ceil（files左/线程左）的语句，后两个变量在天花板功能也是静态的。

我的代码中是否有任何错误，或者我应该简单地测试带有更多单词的较大文本文件，以查看添加线程的速度下降（目前我有5个文本文件，每个文件有20个段落，我得到大约60-70ms）。

Answer 1

写了一段可能有用的代码

public static void main(String[] args) {
    long startTime = System.nanoTime();

    final List<Runnable> tasks = generateTasks(NUM_TASKS);
    List<Thread> threadPool = new LinkedList<>();

    for(int i = 0; i < NUM_THREADS; i++) {
        Thread thread = new Thread(() -> {
            Runnable task = null;
            while ((task = getTask(tasks)) != null) {
                task.run();
            }
        });
        threadPool.add(thread);
        thread.start();
    }

    for(Thread thread: threadPool) {
        try {
            thread.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

    long runTimeMs = (System.nanoTime() - startTime) / 1000000;
    System.out.println(String.format("Ran %d tasks with %d threads in %d ms", NUM_TASKS, NUM_THREADS, runTimeMs));
}

private static Runnable getTask(List<Runnable> tasks) {
    synchronized (tasks) {
        return tasks.isEmpty() ? null : tasks.remove(0);
    }
}