スレッドでサーバーへの接続を維持していますか？

Question

私のプログラムをマルチスレッドにする方法をよく分かりません。基本的に私は接続して動作させるキューサーバーを持っていますが、より多くのスレッドを起動してより速く作業を送信すると、スレッドがブロックされていることがわかります。

ここに私がやっていることの例があります（私のプログラムでは、共有接続から派生したいくつかのデータとチャンネルを送信しています）。

class Send_to_Queue implements Runnable{ 

    protected String queue_name = null; 
    protected Channel channel = null; 
    protected byte[] message = 0 

    public Send_to_Queue(String queue_name, byte[] message, Channel channel) { 
     // TODO Auto-generated constructor stub 
     this.queue_name = queue_name; 
     this.message = message; 
     this.channel = channel;   
    } 

チャネルは、ブロックされているすべてのスレッドが共有するスレッドに固有のものではありません。私はThreadPoolExecutorの人生の中で新しいチャンネルを作成し、各タスクで新しいもの（高価なもの）を作成しないようにする方法がわからないため、これを行うための最善の方法を少し混乱させるだけです。仕事がない場合はシャットダウンしても問題ありませんが、4スレッドと100ユニットのワークがあれば、新しいチャンネルを100回ではなく4回だけ作成したいと思っています。

私は新しいチャンネル/私のサーバーへの接続は、すべてのインスタンスに確立されていない方法でそれを行う方法を理解していないようです。スレッドに接続を渡すと、新しいチャネル（this.channelの下に新しいチャネル毎回作成された）

Answer 1

を開始、それを持つ私はあなたがThreadが構築されたとき、それは、このチャネルを使用して行うことができるように新しいChannelを作成したいと思います並行作業。これを行うにはいくつかの異なる方法があります。通常、サーバーのシナリオでは、サーバーはその接続に新しいChannelを生成する接続を受け入れます。そしてChannelをハンドラThreadに渡します。ここでは、ソケットと同じだが、あなたのアイデアを得る：

ServerSocket socket = ... 
... 
while (true) { 
    Socket clientSocket = socket.accept(); 
    new Thread(new MyRunnable(clientSocket)).start(); 
} 
... 
public class MyRunnable implements Runnable { 
    private Socket clientSocket; 
    public MyRunnable(Socket clientSocket) { 
     this.clientSocket = clientSocket; 
    } 
    public void run() { 
     while (!done) { 
      // use the socket associated with this thread 
     } 
    } 
} 

あなただけのリモートサーバーへの接続を行うために、スレッドの束を作成しているし、あなたがループ内でまたはExecutorServiceプールのいずれかを使用していることを行うことができます動作しない場合：

ExecutorService threadPool = Executors.newFixedThreadPool(100); 
for (int i = 0; i < 100; i++) { 
    threadPool.submit(new Runnable() { 
     public void run() { 
      Channel threadChannel = // create channel here; 
      while (!done) { 
       // use the per-thread channel 
      } 
     } 
    }); 
} 

もう一つの人気パターンは、スレッドが一連のユニットで動作するようにSocketまたはChannelを使用することです。その目的でBlockingQueueを使用することができます。

BlockingQueue<WorkUnit> workQueue = new LinkedBlockingQueue<WorkUnit>(); 
... 
// add work units to the work queue 
for (int i = 0; i < 1000; i++) { 
    // add work to the queue 
    workQueue.put(new WorkUnit(i)); 
} 

// the MyRunnable above can then be modified like this: 
    ... 
    public void run() { 
     while (!done) { 
      WorkUnit workUnit = workQueue.take(); 
      // use MyRunnable socket or channel and do the WorkUnit 
     } 
    }