新しいソケットを受け入れるコードが保持されている間、変数を確認するにはどうすればよいですか？

Question

私が作ったアプリケーションでは、サーバーはクライアントからのソケット接続を受け入れ、さまざまな作業を行います。クライアントのリストは、LinkedListタイプのclientsに格納されています。

私は、clientsキューのサイズに基づく条件文を使ってwhile文を使用しています。

以下に説明する問題を解決する方法があるかどうかを知りたいので、サーバーが永遠にハングしないようにします。

while(clients.size()>0){ //few clients the queue is alive at the moment 
    //Suddenly, all clients in the queue shut down at this point in the while loop, 
    //Another thread, which checks clients knows that clients are dead 
    //so clients.size() becomes 0, but there is no way to check that at this point 
    //and server is expecting for connection clients forever 

    Socket socket= server.accept(); 
    socket.close(); 
} 
//printout results 

編集

クライアントリストだけで既存のクライアントではありません。これは生きているクライアントのリストです。このリストは別のスレッドによって更新されます。

私は上記のステートメントを持っています。生き残ったクライアントが残っていない状態で仕事をしたいからです。 （仕事が終了したばかりか、死亡したばかりか）

タイムアウト例外を使わずにこの問題を解決したいのは、クライアントがランダムに応答するからです。 （もう一度、ハートビート技術を使って別のスレッドでクライアントの活性をチェックします）

Answer 1

あなたはServerSocketにタイムアウトを設定し、SocketTimeoutExceptionキャッチすることができます：

server.setSoTimeout(1000); 
while (clients.size() > 0) { 
    try { 
     server.accept(); 
    } 
    catch (SocketTimeoutException e) { 
     // Ignore 
    } 
} 

2番目かそこらのすべてのクライアントリストのステータスをチェックします。この道を。

他のスレッドがアクセスしている場合は、clientsへのアクセスを忘れないようにしてください。 Collections.synchronizedListを使用してラップするか、変数にアクセスするコードの部分に適切な同期を設定します。

Answer 2

ループ状態はわかりません。既存のクライアントがある場合に新しいクライアントを受け入れることに興味があるのはなぜですか？このプロセスはどのように開始されますか？

一般的に、ServerSocketのタイムアウトを設定すると、accept（）メソッドはSocketTimeoutExceptionsをそれらの間隔でスローし、テストする必要があるものをテストできます。

Answer 3

私はあなたの質問を完全に理解しているとは確信していませんが、いくつかのことを前提にすると以下のように動作するかもしれません。最初に想定しているのは、クライアントクラスにフラグaliveが存在するかどうかを示すものです。

while(clients.size()>0){ 
    client = clients.remove(); 
    if (client.isAlive()) { 
     Socket socket= server.accept(); 
     socket.close(); 
    } 
} 

Answer 4

既知の点でクライアントのサイズが変更されるように、クライアントの同期が必要なように見えます。

Answer 5

すべてのクライアントがなくなったときに、serversocketを停止する余分なスレッドはどうですか？ :)何かのように

new Thread() { 
    public void run() { 
     if (clients.isEmpty()) { 
      try { server.close();} catch (IOException e){...} 
     } 
    } 
}.start(); 

while(clients.size()>0){ 
    if (!clients.isEmpty()) { 
     Socket socket= server.accept(); 
     socket.close(); 
    } 
}