我有多个线程（现在假设是两个），每个线程都检索一个 HTML 页面并将其内容写入一个文件。需要注意的是，每个线程都想写入同一个输出文件。具有 run() 方法的类是静态内部类。我想采取的方法是让每个线程将它想要写入的内容放入队列中。然后，在线程完成（或所有线程都完成）后，遍历队列并将内容打印到文件中。我不确定如何实现这一点。同样，实现可运行接口的类是静态的。我并不精通并发，也不一定想做任何花哨的事情。对于简单的实现有什么建议吗？
【问题讨论】：
标签： java multithreading concurrency
您可以使用 java.util.concurrent 包中的 BlockingQueue。您的每个线程都会将其输出放入队列，第三个线程会将元素从队列中取出并将它们写入文件。 Blocking Queue 的 API 页面上有一个示例，您应该可以将其用于您的实现。您只需要提供produce 和consume 的实现即可。
【讨论】：
您可以使用单线程 ExecutorService。这可用于在生成数据时写入数据（而不必等待。
static final ExecutorService logger = Executors.newSingleThreadExecutor();
static void writeToFile(final FileOutputStream fos, final String text) {
logger.execute(new Runnable() {
public void run() {
try {
fos.write(text.getBytes());
} catch (IOException e) {
e.printStackTrace();
}
}
});
}
【讨论】：
您也可以使用synchronized 块。
【讨论】：
嗯，根据你的描述，我认为你的制作人应该是这样的：
private static final int CAPACITY = 10; // whatever you like here.
private static Object locker = new Object();
private static Queue<String> queue = new ArrayBlockingQueue<String>(CAPACITY);
private static class ThreadTask implements Runnable {
@Override
public void run() {
// retrieve page
// add result to queue
}
}
当然，你可以在一个Executor中执行这些ThreadTask，以便更好的利用系统资源，如果你实现了生产者-消费者队列系统，你的消费者线程也可以和生产者同时运行。
【讨论】：