java中最簡單的方法是在單獨的線程中運行多個方法並等待所有方法都會完成？

Question

我想運行在分離的線程 2種或多個方法的方法。我想確保在所有線程完成之前方法不會完成。

Answer 1

最好的辦法是利用執行人服務API來管理一個線程池，而不是開始對自己的一個開放式的線程數的。

ExecutorService pool = Executors.newCachedThreadPool(); 
for (Runnable r : new Runnable[] { 
    new R() { void r() { myMethod1(); }}, 
    new R() { void r() { myMethod2(); }}, 
}) 
    pool.execute(r); 
pool.shutdown(); 
pool.awaitTermination(60, TimeUnit.SECONDS); 

---

abstract class R implements Runnable 
    public final void run() { r(); } 
    abstract void r(); 
} 

---

請注意，這是不可取的堅持在其自己的，獨立的線程運行的每一個方法。線程相當重量級（每個線程分配一個完整的調用棧），並且性能實際上隨線程數量增加遠遠超出可用處理器內核的數量而降低。

Answer 2

我的解決辦法是

功能：

public void runParallel(Runnable... runnables) throws InterruptedException { 

List<Thread> threads = new ArrayList<Thread>(runnables.length); 

for (Runnable runnable :runnables) { 
    Thread th = new Thread(runnable); 
    threads.add(th); 
    th.start(); 
} 

for (Thread th : threads) { 
    th.join(); 
} 

用途：

runParallel(new Runnable() { 
       @Override 
       public void run() { 
        method1() 
       } 
      }, new Runnable() { 
       @Override 
       public void run() { 
        method2() 
       } 
      } 
); 

更好的想法？也許有是我不知道的一個較短的方式;）

Answer 3

我更喜歡這樣的事情：

public static void runParallel(Runnable... runnables) throws InterruptedException { 
    final CountDownLatch done = new CountDownLatch(runnables.length); 
    for (final Runnable r: runnables) { 
     new Thread(new Runnable() { 
      public void run() { 
       try { 
        r.run(); 
       } finally { 
        done.countDown(); 
       } 
      } 
     }).start(); 
    } 
    done.await(); 
} 

這種方法的優點是，它也可以與線程池（即可以取代new Thread(...).start()與executor.submit(...)）。

此外，它允許您使用基於awaitTermination()，迫使你創建的每個調用新池預先存在的線程池，不同的解決方案。

Answer 4

繼damienix給出的API：

public void runParallel(Runnable... runnables) throws InterruptedException { 
    final ExecutorService pool = Executors.newFixedThreadPool(runnables.length); 
    for (Runnable runnable: runnables) { 
     pool.submit(runnable); 
    } 
    pool.shutdown(); 
    pool.awaitTermination(1, TimeUnit.MINUTES); 
}