Đồng bộ hóa trong chủ đề cho Java

Question

Tôi có một máy chủ web được phát triển trong ứng dụng của mình. Máy chủ web này sinh ra một chuỗi mới cho mọi yêu cầu đi vào ổ cắm để được chấp nhận. Tôi muốn máy chủ web đợi cho đến khi một điểm cụ thể được nhấn vào chuỗi mà nó vừa tạo.

Tôi đã trải qua nhiều bài đăng trên trang web này và các ví dụ trên web, nhưng không thể yêu cầu máy chủ web tiếp tục sau khi tôi yêu cầu chuỗi chờ. Một ví dụ mã cơ bản sẽ là tuyệt vời.

Từ khóa được đồng bộ hóa có đúng cách để thực hiện việc này không? Nếu vậy, làm thế nào điều này có thể đạt được? Mã số ví dụ dưới của ứng dụng của tôi:

Web Server

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); 
    } 
} 

Chủ đề đang

public void run() { 
    //code here 

    //notify web server to continue here 
} 

Update - Mã cuối cùng là như dưới đây. Các HttpRequest không chỉ cần gọi resumeListener.resume() bất cứ khi nào tôi gửi một đáp ứng tiêu đề (tất nhiên cũng có thêm giao diện như là một lớp riêng biệt và addResumeListener(ResumeListener r1) phương pháp trong HttpRequest):

phần Web Server

// 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

Trước hết, tôi lặp lại cảm xúc của người khác rằng việc phát minh lại bánh xe ở đây rất có thể sẽ dẫn đến nhiều vấn đề khác nhau cho bạn. Tuy nhiên, nếu bạn muốn đi xuống con đường này thì những gì bạn đang cố gắng làm là không khó. Bạn đã thử nghiệm với Jetty chưa?

Có lẽ một cái gì đó như thế này:

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

Bạn có thể sử dụng java.util.concurrent.CountDownLatch với tổng số là 1 cho điều này. Sắp xếp cho một ví dụ của nó được tạo ra và được chia sẻ bởi các chủ đề cha và con (ví dụ, tạo nó trong constructor HttpRequest ', và có nó có thể truy xuất bởi một hàm thành viên). Máy chủ sau đó gọi số await() trên đó và chuỗi truy cập countDown() khi nó sẵn sàng phát hành phụ huynh của nó.

Answer 3

Có thể bạn cần sử dụng Java Condition. Từ các tài liệu:

Điều kiện (còn gọi là tình trạng hàng đợi hoặc các biến điều kiện) cung cấp một phương tiện cho một thread để đình chỉ thực hiện (để "chờ") cho đến khi thông báo bởi thread khác mà một số nhà nước tình trạng bây giờ có thể đúng.

Answer 4

Chạy dưới trình gỡ rối và đặt điểm ngắt?

Nếu không đọc được, hãy đọc một dòng từ System.in?