whileループで2つのサーバースレッドが互いにブロックしています

Question

皆さん。 私は2つのスレッドを持っていますが、これはクライアントからの接続を処理することが任されています。

私は、サーバーがブロックし、動作を停止し、クライアントをブロックするが、私はこれを削除した場合、この現象が発生しないだろう、loginSocketに2回接続しようとするとこれは私のコード

ServerSocket loginSocket = new ServerSocket(8000); 
ServerSocket fileSocket = new ServerSocket(7000); 

while (running) { 
    new LoginThread(loginSocket.accept(),loginInormation).start(); 
    new LoaderThread(fileSocket.accept()).start(); 
} 

です：

new LoginThread(loginSocket.accept(),loginInormation).start(); 

エラーメッセージが表示されないのはなぜですか。これがどうして起こりますか？これをどのように修正できますか？

Answer 1

accept()メソッドはブロックメソッドです。つまり、loginSocket()で接続するまでプログラムが続行されません。

LoginThreadを作成するとき、プログラムは接続を待ってオブジェクトの最初のパラメータを設定し、接続が確立されるまで実行を継続しません。

Answer 2

行new LoginThread(loginSocket.accept(),loginInormation).start();には、このスレッドが作成される前に呼び出されるloginSocket.accept()というメソッド呼び出しが含まれています。このメソッド呼び出しは、クライアントがログインするまでブロックされます（さらに、2番目のスレッドはfileSocket.accept()によってブロックされます）。

解決策としては、accept()呼び出しを各スレッドの内部に移動します。これを行うには、ソケットにスレッドを渡す必要があります。

Answer 3

異なるスレッドで

スタートfileSocketとログインソケット

package com.ca.training.task.app; 

import java.io.IOException; 
import java.net.ServerSocket; 

public class App { 

    public void execute() { 
     LoginRunnable loginRunnable = new LoginRunnable(); 
     loginRunnable.setLoginInformation(new Object());//Login information 

     FileRunnable fileRunnable = new FileRunnable();//Data for loaded runnable. 
     fileRunnable.setParams(new Object()); 

     startLoginThread(loginRunnable); 
     startFileThread(fileRunnable); 
    } 

    private static void startLoginThread(LoginRunnable loginRunnable) { 
     Thread loginThread = new Thread(loginRunnable); 
     loginThread.start(); 
    } 

    private static void startFileThread(FileRunnable fileRunnable) { 
     Thread loadedThread = new Thread(fileRunnable); 
     loadedThread.start(); 
    } 

    class LoginRunnable implements Runnable { 

     private Object loginInformation; 

     @Override 
     public void run() { 
      try { 
       ServerSocket loginSocket = new ServerSocket(8000); 
       loginSocket.accept(); 
      } catch (IOException e) { 
       e.printStackTrace(); 
      } 
     } 

     public Object getLoginInformation() { 
      return loginInformation; 
     } 

     public void setLoginInformation(Object loginInformation) { 
      this.loginInformation = loginInformation; 
     } 
    } 

    class FileRunnable implements Runnable { 

     private Object params; 

     @Override 
     public void run() { 
      try { 
       ServerSocket fileSocket = new ServerSocket(7000); 
      } catch (IOException e) { 
       e.printStackTrace(); 
      } 
     } 

     public Object getParams() { 
      return params; 
     } 

     public void setParams(Object params) { 
      this.params = params; 
     } 
    } 
}