如何用Java实现多线程池

Question

我有一个使用线程的场景。

首先，我有一个文件夹，里面有经常更新的文件。 因此，我编写了一个线程，它读取文件夹的内容并将文件名写入静态列表，并在有新文件进入时更新该列表。

其次，我编写了另一个线程，它从列表中获取文件名并进行一些处理文件。

这两个线程连续运行，一个检查新文件，一个处理新文件。

现在我需要在运行三个线程的情况下一次处理三个文件。当一个线程完成处理时，另一个线程从列表中获取另一个文件名并启动该进程。

因此，我需要某种机制来拥有三个线程并检查它们是否还活着，并相应地启动一个新线程，并且文件列表也会经常更新。

我还研究了 ExecutorService，但是当列表更新时我无法提供更新的列表。

谢谢， 桑迪普

Answer 1

基于现有的答案，您的代码看起来像这样：

    final ExecutorService executor = Executors.newFixedThreadPool(2);

    final FilePoller poller = ...
    final FileProcessor processor = ...

    new Thread(new Runnable() 
      { 
        @Override
        public void run() 
        {
          while (true)
          {
            final File file = poller.pollForFile();
            executor.submit(new Runnable() { public void run() { processor.processFile(file); } } );
          }
        }
      });

假设您的处理器可以跟上轮询器，这很好，否则您需要在提交给执行器之前添加一些限制机制。

Answer 2

不要使用列表；相反，使用 java.util.concurrent.ThreadPoolExecutor 并将代表要处理的文件的 Runnable 放入执行器中，而不是将它们放入全局列表中。

Answer 3

与@SimonC的建议类似，但我没有一个很长的评论，而是有一个答案。

final FilePoller poller = ...
final FileProcessor processor = ...

final ExecutorService executor = Executors.newFixedThreadPool(4);

executor.submit(new Runnable() { 
    public void run() {
        final File file = poller.pollForFile();
        executor.submit(new Runnable() { public void run() { processor.processFile(file); } } );
        // repeat, but wait for a free thread.
        executor.submit(this);
    }
  });
 // to stop the whole thing
 executor.shutdown();

Answer 4

假设通知更改为您提供了文件夹中的更改列表，那么监视文件夹中的更改并生成一个线程/文件怎么样？