Java用スレッドの同期

Question

私のアプリに自宅のWebサーバーがあります。このWebサーバーは、ソケットに入ってくるすべての要求に対して新しいスレッドを生成します。私は、Webサーバが、作成したばかりのスレッドで特定のポイントに達するまで待つ必要があります。

私は、このサイトとWeb上の例で多くの記事を読んできましたが、スレッドに待つように指示してからWebサーバーを起動できません。基本的なコード例は素晴らしいでしょう。

synchronizedキーワードはこれについて正しい方法ですか？もしそうなら、これはどのように達成できますか？コード例は、私のアプリの下にある：

Webサーバー

while (true) { 
    //block here until a connection request is made 
    socket = server_socket.accept(); 

    try { 
    //create a new HTTPRequest object for every file request 
    HttpRequest request = new HttpRequest(socket, this); 

    //create a new thread for each request 
    Thread thread = new Thread(request); 

    //run the thread and have it return after complete 
    thread.run(); 

    /////////////////////////////// 
    wait here until notifed to proceed 
    /////////////////////////////// 
    } catch (Exception e) { 
    e.printStackTrace(logFile); 
    } 
} 

スレッドコード

public void run() { 
    //code here 

    //notify web server to continue here 
} 

アップデート - 最終的なコードは以下の通りです。私はレスポンスヘッダを送信するたびHttpRequestだけで（もちろん、別のクラスとしてインターフェイスとHttpRequestでaddResumeListener(ResumeListener r1)メソッドを追加）resumeListener.resume()を呼び出しん：

Webサーバーの部分を使用でき

// server infinite loop 
while (true) { 

    //block here until a connection request is made 
    socket = server_socket.accept(); 

    try { 
    final Object locker = new Object(); 

    //create a new HTTPRequest object for every file request 
    HttpRequest request = new HttpRequest(socket, this); 

    request.addResumeListener(new ResumeListener() { 
     public void resume() { 
     //get control of the lock and release the server 
     synchronized(locker) { 
      locker.notify(); 
     } 
     } 
    }); 

    synchronized(locker) { 
     //create a new thread for each request 
     Thread thread = new Thread(request); 

     //run the thread and have it return after complete 
     thread.start(); 

     //tell this thread to wait until HttpRequest releases 
     //the server 
     locker.wait(); 
    } 
    } catch (Exception e) { 
    e.printStackTrace(Session.logFile); 
    } 
} 

Answer 1

まず、私はここで車輪を再発明することで、あなたのためにさまざまな問題につながる可能性が高いと他人の感情をエコーし​​ます。しかし、あなたがやっていることをとにかくこの道を歩きたいのであれば、難しいことではありません。あなたは桟橋で実験しましたか？

たぶん、このような何か：

public class MyWebServer { 

    public void foo() throws IOException { 
    while (true) { 
     //block here until a connection request is made 
     ServerSocket socket = new ServerSocket(); 

     try { 
     final Object locker = new Object(); 
     //create a new HTTPRequest object for every file request 
     MyRequest request = new MyRequest(socket); 
     request.addResumeListener(new ResumeListener() { 
      public void resume() { 
      locker.notify(); 
      } 
     }); 
     synchronized(locker){ 

      //create a new thread for each request 
      Thread thread = new Thread(request); 

      //start() the thread - not run() 
      thread.start(); 

      //this thread will block until the MyRequest run method calls resume 
      locker.wait(); 
     } 
     } catch (Exception e) { 
     } 

    } 
    } 
} 

public interface ResumeListener { 
    public void resume(); 
} 

public class MyRequest implements Runnable{ 
    private ResumeListener resumeListener; 

    public MyRequest(ServerSocket socket) { 
    } 

    public void run() { 
    // do something 
    resumeListener.resume(); //notify server to continue accepting next request 
    } 

    public void addResumeListener(ResumeListener rl) { 
    this.resumeListener = rl; 
    } 
} 

Answer 2

これのために1のカウントを有するjava.util.concurrent.CountDownLatch。そのインスタンスが作成され、親スレッドと子スレッドによって共有されるように調整します（たとえば、HttpRequestのコンストラクターで作成し、メンバー関数によって取得可能にします）。その後、サーバはawait()を呼び出し、そのスレッドは親を解放する準備ができたらcountDown()に達する。

Answer 3

おそらくJava Conditionを使用する必要があります。ドキュメントから：

条件（も条件として知られている キューや条件変数）他のスレッドによって通知さ まで（「待つ」へ） 実行を中断するために、1つのスレッドのため 手段を提供するいくつかの状態 条件今は真実かもしれない。

Answer 4

デバッガの下で実行すると、ブレークポイントを設定しますか？

実行できない場合は、System.inから行を読み込みますか？