如何调用使用多线程而不是按顺序的方法

Question

我的两个类中有一个接受字符串映射的进程方法。

在下面的代码中，我使用了一个for循环，它将逐个调用我的两个类中的process方法，这很好。

for (ModuleRegistration.ModulesHolderEntry entry : ModuleRegistration.getInstance()) { 
    final Map<String, String> response = entry.getPlugin().process(outputs); 

    System.out.println(response); 
} 

但是有没有什么办法可以为此启动两个线程？一个线程会调用我的一个类的进程方法，第二个线程会调用我的第二个类的进程方法？然后在得到每个线程的响应之后，我想写入数据库。这意味着每个线程将写入数据库。

而且每个线程也应该有超时功能。我们将等待每个线程一段指定的时间，这意味着如果某个进程方法没有在一定时间内返回，那么它将获得超时。

这是可能做我的使用情况？如果是的话，任何人都可以提供一个如何做到这一点的例子吗？谢谢。

任何帮助将不胜感激。

Answer 1

您可以创建一个ExecutorService，并分配您想要运行的多个线程，例如，

ExecutorService executor = Executors.newFixedThreadPool(2) 

里面现在你的循环，你会做这样的事情

for (ModuleRegistration.ModulesHolderEntry entry : ModuleRegistration.getInstance()) { 
    executor.submit(new Runnable() { 
     public void run() { 
      final Map<String, String> response = entry.getPlugin().process(outputs); 
      // write to database 
      System.out.println(response); 
     } 
    } 
} 

您可能还需要有一个单独的线程处理所有数据库的写入 - 您可运行将通过发送它们的结果吧一个BlockingQueue或沿着这些线

// Three threads: one thread for the database writer, two threads for the plugin processors 
final ExecutorService executor = Executors.newFixedThreadPool(3); 

final BlockingQueue<Map<String, String>> queue = new LikedBlockingQueue<>(); 

Future future = executor.submit(new Runnable() { 
    public void run() { 
     Map<String, String> map; 
     try { 
      while(true) { 
       // blocks until a map is available in the queue, or until interrupted 
       map = queue.take(); 
       // write map to database 
      } 
     } catch (InterruptedException ex) { 
      // IF we're catching InterruptedException then this means that future.cancel(true) 
      // was called, which means that the plugin processors are finished; 
      // process the rest of the queue and then exit 
      while((map = queue.poll()) != null) { 
       // write map to database 
      } 
     } 
    } 
} 

for (ModuleRegistration.ModulesHolderEntry entry : ModuleRegistration.getInstance()) { 
    executor.submit(new Runnable() { 
     public void run() { 
      final Map<String, String> response = entry.getPlugin().process(outputs); 
      // put the response map in the queue for the database to read 
      queue.offer(response); 
     } 
    } 
} 

// this interrupts the database thread, which sends it into its catch block 
// where it processes the rest of the queue and exits 
future.cancel(true); // interrupt database thread 

// wait for the threads to finish 
executor.awaitTermination(5, TimeUnit.MINUTES);