java - 如何在Java中的不同对象之间进行等待和通知？

Question

程序的一般用途

要从命令行读取 bash 模式和指定位置，并查找该位置中与该模式匹配的所有文件，但我必须使程序成为多线程。

程序的总体结构

• 解析参数并启动其他类的驱动程序/主类。
• ProcessDirectories 类，将从指定根目录找到的所有目录地址添加到字符串数组中以便稍后处理
• DirectoryData 类，保存在上述类中找到的地址
• ProcessMatches 类，检查找到的每个目录，并将其中与模式匹配的所有文件添加到字符串数组中，以便稍后打印结果
• Main/Driver 再次接管并打印结果:)

问题

即使 ProcessDirectories 类仍在工作，我也需要处理匹配(为了提高效率，所以我不必在工作之前等待列表填充)。为此，我尝试:a)如果 DirectoryData 为空，则使 ProcessMatches 线程 wait() b) 如果添加了新条目，则使 ProcessDirectories notifyAll()。

问题:)

我看的每个教程都集中在同一对象中的生产者和消费者，或者只处理一个数据结构。当我使用多个数据结构和多个类进行生产和消费时，我该如何做到这一点？

Answer 1

怎么样:

class Driver(String args)
{
   ProcessDirectories pd = ...
   BlockingQueue<DirectoryData> dirQueue = new LinkedBlockingQueue<DirectoryData>();
   new Thread(new Runnable(){public void run(){pd.addDirs(dirQueue);}}).start();

   ProcessMatches pm = ...
   BlockingQueue<File> fileQueue = new LinkedBlockingQueue<File>();
   new Thread(new Runnable()
     {
       public void run()
       { 
         for (DirectoryData dir = dirQueue.take(); dir != DIR_POISON; dir = dirQueue.take())
         {
           for (File file : dir.getFiles())
           {
             if (pm.matches(data))
               fileQueue.add(file)
           }
         }
         fileQueue.add(FILE_POISON);
       }
     }).start();

   for (File file = fileQueue.take(); file != FILE_POISON; file = fileQueue.take())
   {
     output(file);
   }
}

当然这只是一个粗略的想法。 ProcessDirectories.addDirs() 只会将 DirectoryData 对象添加到队列中。在生产中，您需要命名线程。也许使用执行器来提供管理线程。也许使用除有害消息之外的其他机制来指示处理结束。另外，您可能希望减少队列大小的限制。