Java：異なるスレッドのオブジェクトを比較する方法

Question

私はクライアントからのデータを受信するサーバーを持っています。クライアントがデータを送信すると、スレッドに入ります。したがって、各スレッドにはデータがあります。 revFeaturePointsは、サーバーがクライアントから受け取るデータです。

各revFeaturePointsには浮動小数点型配列があります。異なるスレッドで異なるrevFeaturePoint間のユークリッド距離を計算しますか？

他のスレッドの別のrevFeaturePointsにアクセスする方法を知りませんか？ここで

はコードです：

public class MyServer { 

public static void main(String[] args) throws IOException{ 
    ServerSocket serverSocket = null; 

    //bind a serverSocket to the port and listen 
    try{ 
     serverSocket = new ServerSocket(8888); 
     System.out.println("Listening: 8888"); 
    }catch(IOException e){ 
     e.printStackTrace(); 
    } 

    while(true) 
     new MyServerThread(serverSocket.accept()).start(); 
} 
} 

public class MyServerThread extends Thread{ 
//Create a socket for each client 
private Socket socket = null; 
private ObjectInputStream dataInputStream = null; 
private ObjectOutputStream dataOutputStream = null; 
private ArrayList<FeaturePointList> revFeaturePoints = null; 

//constructor 
public MyServerThread(Socket socket){ 
    super("MyServerThread"); 
    this.socket = socket; 
} 

@SuppressWarnings("unchecked") 
public void run(){ 
    try{    
     dataOutputStream = new ObjectOutputStream(socket.getOutputStream()); 
     dataInputStream = new ObjectInputStream(socket.getInputStream()); 
     System.out.println("ip: "+ socket.getInetAddress()); 
     revFeaturePoints = (ArrayList<FeaturePointList>) dataInputStream.readObject();   

    }catch(IOException e){ 
     e.printStackTrace(); 
    } catch (ClassNotFoundException e) { 
     // TODO Auto-generated catch block 
     e.printStackTrace(); 
    } 
    finally{ 
     if(socket!=null){ 
      try{ 
       socket.close(); 
      }catch(IOException e){ 
       e.printStackTrace(); 
      } 
     } 
     if(dataInputStream!=null){ 
      try{ 
       dataInputStream.close(); 
      }catch(IOException e){ 
       e.printStackTrace(); 
      }    
     } 
     if(dataOutputStream!=null){ 
      try{ 
       dataOutputStream.close(); 
      }catch(IOException e){ 
       e.printStackTrace(); 
      }    
     } 

    } 
} 

}

Answer 1

簡単な方法は、データを返すMyServerThreadに同期メソッドを置くことです。

これを実行する別の方法は、BlockingQueueを使用してデータ結果をキューに入れ、その結果をプロデューサ/コンシューマパターンとして取得することです。これを行う方法については、hereを参照してください。

Answer 2

あなたMyServerThreadクラスがフィールドにデータをスタッシュ場合、あなたはMyServerThreadの複数のインスタンスからそのフィールドにアクセスすることができます。

Answer 3

共有構造を使用し、同期を正しく行うことで、スレッド間でデータを共有できます。たとえば、MyServerThreadにはConcurrentHashMap<'threadname', data>があり、各スレッドはそのデータを入れて他のスレッドでデータを検索します。

つまり、アーキテクチャを評価する必要があります。 N個のスレッドが他のN-1スレッドがデータで何をしているかを確認する必要がある場合は、パフォーマンスの低下のためのレシピを準備しています。おそらく、あなたのアーキテクチャでは、いくつかのレイヤーを作成して、いくつかのServerThreadsがリクエストを収集し、それらを同時に共有構造（キューなど）に配置することが考えられます。次に、別の作業者がデータを比較して処理し、結果を共同システムで生成しています。 producer-consumer patternをご覧ください。 [本当にコメントますが収まりません。）]

Answer 4

maasgの答えは、一般的な意味では非常に正しいですが、私はあなたが今、Javaはそれ自体の実装をスレッド設計の難しさを見ていないされていると信じています。

サーバーは、接続要求ごとに使い捨てスレッドを起動します。このスレッドはクライアントから1つのオブジェクトを読み取り、接続を閉じます。渡されたオブジェクトは、（サーバースレッド）インスタンススコープオブジェクトに入れられます（run（）を終了した後にガベージコレクションされます）。

これは設計上の問題であるという印象をどのようにして比較するのか、それともどのようにして2つの同時スレッド（常に）があることを保証するのかを決定する方法は完全には不明です。まずは

論理的には、サーバースレッドとドメイン内のいくつかの意味のある問題の間に、ドメイン固有の関連付けがあることは明らかです。この関係はコードで具体化する必要がありますが、まずこの区別と関係が何であるかを理解する必要があります。

Answer 5

オブジェクトは異なるスレッド内にありません。オブジェクトは他の異なるオブジェクトのメンバーで、通常は 'get'メソッドで参照されます。スレッドの問題を完全に忘れてしまっても、それは無関係です。オブジェクトAのメンバーとオブジェクトBのメンバーを比較したいだけです。これは通常どおりのビジネスです。