恢復一個線程並傳入一個Java中的對象

Question

我對Java中的線程比較陌生。我想知道以下是否可能。

• 線程[a]被調用（來自另一個對象）。
• 它做了一些東西，然後在同一個對象中啓動另一個線程[b]。
• 然後它暫停自己並等待另一個線程完成。
• 當它結束時，它將它正在處理的結果傳遞給暫停的線程[a]並恢復它。
• 線程[a]然後將結果返回給調用它的原始對象。

謝謝！

Answer 1

有很多方法可以做到這一點。

以下示例通常是完成任務的最佳方式。它在主線程中執行了一些工作，然後將Callable傳遞給ExecutorService，它在另一個線程中執行一些工作。對future.get的呼叫阻塞，直到第二個線程完成並返回Object，即Callable返回。

private static final ExecutorService executorService = Executors.newFixedThreadPool(1); 

public static void main(String[] args) { 
    //do some stuff  
    final Future<Object> future = executorService.submit(new MyOtherWork()); 
    final Object object; 
    try { 
     object = future.get(); 
    } catch (InterruptedException ex) { 
     Thread.currentThread().interrupt(); 
    } catch (ExecutionException ex) { 
     //handle exception 
    }  
    //do some other stuff 

} 

private static class MyOtherWork implements Callable<Object> { 

    public Object call() throws Exception { 
     //do stuff in another thread 
    } 
} 

注意，爲ExecutorService默認使用非守護線程應用程序不會退出，直到它被關閉。

Answer 2

那麼線程a的SynchronousQueue如何等待take() from和線程b put()是它的結果？

同步隊列類似於CSP和Ada中使用的集合信道。它們非常適合於越區切換設計，其中在一個線程中運行的對象必須與在另一個線程中運行的對象同步，以便交付一些信息，事件或任務。

如果你想添加超時，讓線程poll()爲結果和線程b offer()它。

Answer 3

如果你想在Java中使用線程來簡化你的生活，請不要使用wait（），notify（）你將不得不使用同步的方法和語句，我的建議是使用ReentrantLock和Condition主線程從線程

Here you can read more about it

Answer 4

我認爲你要找的是java.util.Callable和java.util.Executors。

這是我可以寫最短的代碼是：

import java.util.concurrent.Callable; 
import java.util.concurrent.ExecutionException; 
import java.util.concurrent.ExecutorService; 
import java.util.concurrent.Executors; 

public class TestCallable { 

    public static void main(String[] args) throws InterruptedException, ExecutionException { 

     ExecutorService executor = Executors.newSingleThreadExecutor(); 
     try { 
      Integer five = executor.submit(new Callable<Integer>() { 

       @Override 
       public Integer call() throws Exception { 
        ExecutorService executor = Executors.newSingleThreadExecutor(); 
        try { 
         return executor.submit(new Callable<Integer>() { 

          @Override 
          public Integer call() throws Exception { 
           return 5; 
          } 

         }).get(); 
        } finally { 
         executor.shutdown(); 
        } 
       } 

      }).get(); 

      System.out.println(five); // prints 5 

     } finally { 
      executor.shutdown(); 
     } 
    } 
}