線程間消息傳遞的實現

我想要做的是讓一個線程將它從父線程接收到的消息寫入一個OutputStream，監聽一個InputStream的回覆，然後通過回覆通知父線程。我寫了兩個測試類，它們以不同的方式做類似但更簡單的測試。方法1僅在"before loop"調試語句未註釋時才起作用，方法2僅打印"message from child"調試語句。我究竟做錯了什麼？線程間消息傳遞的實現

方法1

public class Parent { 
    private static int out = 0; 
    private static int in = 0; 

    public static void main(String[] args) { 
     final Object locker = new Object(); 
     Thread t = new Thread(new Runnable() {   
      @Override 
      public void run() { 
       while (true) { 
        synchronized (locker) { 
         try { 
          locker.wait(); 
          System.out.println("Message from parent " + out); 
          in = out + 10; 
          locker.notify(); 
         } catch (InterruptedException e) { 
          // TODO Auto-generated catch block 
          e.printStackTrace(); 
         } 
        } 
       } 
      } 
     }); 
     t.start(); 

     System.out.println("before loop"); 
     while (out < 10) { 
      synchronized (locker) { 
       locker.notify(); 
       try { 
        locker.wait(); 
        out++; 
        System.out.println("Message from child " + in); 
       } catch (InterruptedException e) { 
        // TODO Auto-generated catch block 
        e.printStackTrace(); 
       }    
      } 
     }  
    } 
}

方法2

public class Parent { 

    /** 
    * @param args 
    * @throws InterruptedException 
    */ 
    public static void main(String[] args) throws InterruptedException { 
     final BlockingQueue<Integer> q = new ArrayBlockingQueue<Integer>(1); 

     Thread t = new Thread(new Runnable() {   
      @Override 
      public void run() { 
       while (true) { 
        try { 
         Integer i = q.take();    
         System.out.println("Message from parent: " + i.intValue()); 
         q.put(i.intValue() + 10); 
        } catch (InterruptedException e) { 
         // TODO Auto-generated catch block 
         e.printStackTrace(); 
        } 
       }    
      } 
     }); 

     for (int i = 0; i < 10; i++) { 
      q.put(i); 
      Integer j = q.take(); 
      System.out.println("Message from child: " + j); 
     } 
    } 

}

來源

2012-04-15 Johnny

Java API已經提供了該功能;你有沒有充分的理由重新發明車輪？

public static void main(String[] args) throws Exception { 
    // start a worker thread 
    ExecutorService exec = Executors.newFixedThreadPool(1); 

    // ask the worker thread to execute a task (
    Future<String> future = exec.submit(() -> { 
     Thread.sleep(500); // simulate waiting for I/O 
     return "hello from child"; 
    }); 

    // get the return value from the worker thread (waiting until it is available) 
    String greeting = future.get(); 
    System.out.println(greeting); 

    // terminate the worker thread (otherwise, the thread will wait for more work) 
    exec.shutdown(); 
}

來源

2012-04-15 14:38:20 meriton

不是真的，我只是不太瞭解java :-)謝謝！ – Johnny 2012-04-15 15:10:52

在方法1你有一個好的食譜僵局，因爲孩子不前父線程可以執行其第一notify()其第一個wait()。這將導致他們兩人都在等待，既無法通知。由於這是一種競爭條件，因此打印語句等微不足道的事情可能會影響實踐中的行爲。

方法2同樣設計不好，因爲你有兩個線程都從同一隊列寫入和讀取。嘗試使用兩個隊列，一個是父項寫入和子項讀取，另一個是子項寫入和父項讀取。

來源

2012-04-15 14:16:46

線程間消息傳遞的實現

回答

相關問題