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

Question

我有多个线程从同一个队列写入和读取。我正在使用并发链接队列。任何线程都可以将一个元素添加到队列中，任何其他线程都可以轮询一个元素并对其进行处理。我的问题是，如果队列为空，我想让正在轮询队列的线程等待，直到某个元素被其他线程添加到它，如果所有线程都在等待，即没有线程正在写入，则整个进程应该退出。我正在使用它来列出目录及其子目录中的所有文件#faster scan。

以下是代码片段 1:

{

私有(private)队列 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();
}
}
}

上面的代码对吗？它是否一直做我想做的事。虽然程序运行良好，但我不明白线程是如何退出的，因为我没有提到任何退出条件。

在ConcurrentLinkedQueue上使用synchronized对吗？这也适用于大目录吗？编辑1:使用LinkedBlockingQueue，但是当所有线程都处于等待状态意味着不再需要扫描目录时如何退出？它会使用一个静态变量，增加它并检查它是否等于 numberofthreads，然后退出。它有效还是有更好的解决方案？

编辑 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

这使得您可以拥有消费者线程和生产者线程，并且您不必自己进行任何锁定或同步。您只需使用 take() 或执行 put(item) ，如果没有空间放置该项目或没有项目可取，线程将等待。它为您进行相关的锁定和解锁。并且只有当它不能真正拿到元素或把它放在那里时才会等待。还有会超时的操作等。

    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，它是线程安全的。你正在做的是实现阻塞。有很多事情可以解释这应该如何完成。无论您等待和通知什么对象(尽管必须是同一个对象)，都适用相同的规则。

• 你需要在一个线程中 wait() 而在另一个线程中 notify() (我不能告诉你的代码中是否属于这种情况)。
• 您需要在同一对象上同步的同步块(synchronized block)中执行此操作。 (正确)
• 但是，您似乎没有实现任何其他要求。等待前需要检查队列是否为空，每次无缘无故的等待是没有意义的。