多线程写入和多线程读取的并发问题。#快速目录扫描

Question

我有多个线程从同一队列中写入和读取。我正在使用ConcurrentLinkedQueue。任何线程都可以向队列中添加元素，任何其他线程都可以轮询元素并对其进行处理。我的问题是，如果队列是空的，我想让在队列上轮询的线程等待，直到其他线程将某个元素添加到队列中，如果所有线程都在等待，那么整个进程都应该退出，即不再有线程在写。我用它列出一个目录及其子目录中的所有文件#更快地扫描。

以下是代码片段1：

{

private Queue dList=new ConcurrentLinkedQueue（）；

/*一些处理代码*/

public void Run
{
/* some processing code */
while(dName == null)
{
try{
synchronized(dList){
dList.wait();
}
} catch(InterruptedException e){}
dName = dList.poll();
}

/* some processing code */
{
dList.add(item);
synchronized(dList){
dList.notifyAll();
}
}
}

以上代码正确吗？它能一直满足我的需求吗。虽然程序运行良好，但我不理解线程是如何退出的，因为我没有提到任何退出条件。

使用同步是正确的吗？这也适用于大型目录吗？编辑1：使用LinkedBlockingQueue，但是当所有线程都处于等待状态时，这意味着没有更多的目录需要扫描时，如何退出？有一个静态变量，递增并检查它是否等于线程数，然后退出。这有效吗？或者有更好的解决方案吗？

编辑2：谢谢大家。从线程退出由AtomicInteger解决。如果所有线程都在队列中等待，那么它们的AtomicInteger将递增，如果AtomicInteger等于线程数，则中断；

Answer 1

你所描述的是阻塞。你最好使用一个专门做这件事的数据结构，比如ArrayBlockingQueue，而不是卷起你自己的数据结构。它可以并发，但也有访问队列的阻塞方式，迫使正在运行的线程等待，直到有一个项目要获取。所有需要的锁定等等。你也可以用LinkedBlockingQueue做无界的事情

https://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ArrayBlockingQueue.html https://docs.oracle.com/javase/7/docs/api/java/util/concurrent/LinkedBlockingQueue.html

这使得你可以拥有消费者线程和生产者线程，你不必自己做任何锁定或同步。你只需使用“拿”（）或“放”（项目），如果没有空间放那个项目或者没有项目可以拿，线程就会等待。它为你做相关的锁定和解锁。只有当它不能真正得到项目或把它放在那里时才会等待。还有一些操作会超时等等。

    new Thread(new Runnable() {
        @Override
        public void run() {
            while (true) {
                if (Thread.currentThread().isInterrupted()) return;
                try {
                    File file = blockingqueue.take();
                } catch (InterruptedException ignored) {
                    return;
                }
                processFile(file);
            }
        }
    }).start();

您实际上不必同步ConcurrentLinkedQueue，它是线程安全的。你所做的是实现阻塞。有很多事情可以解释如何做到这一点。不管你在哪个对象上等待和通知（尽管必须是同一个对象），都适用相同的规则。

• 您需要在一个线程中等待（）并在另一个线程中通知（）（我不知道代码中是否存在这种情况）
• 需要在同一对象上同步的同步块中执行此操作。（正确）
• 但是，您似乎没有实现任何其他要求。在等待之前，你需要检查队列是否为空，没有理由每次都等待是没有意义的