"固定"/"ロードバランス" C＃スレッドプール？

Question

私はスピンアップするのに "高価な"サードパーティのコンポーネントを持っています。このコンポーネントはスレッドセーフではありません。上記のコンポーネントはWCFサービスの中でホストされているので（今のところ）、サービスを呼び出すたびに新しいコンポーネントを作成する必要があります。私が代わりにやってみたい何

は、各コンポーネントの独自のコピーをスピンアップし、メソッドを呼び出すための仕組みを持っており、それが16件のスレッドの1に配布していると持っている16個のスレッドを言うのプールを持っています戻り値

だから、のような単純なもの：私は続行する応答を必要として、それが応答を取得するまで呼び出しがブロックするため

var response = threadPool.CallMethod(param1, param2); 

その罰金。

提案がありますか？たぶん私はそれと16件のスレッドによってサービスされるConcurrentQueueが仕事をするだろうoverthinkingんだけど、メソッドの戻り値は、呼び出し元に返さなるだろうか、今確認してください？あなたはそれだけでひどく行くために起こっていることの上にスレッド管理の層を追加するので、もし

Answer 1

WCFは、すでにそのリソースを管理するためのスレッドプールを使用します。可能な場合は、サービスコールの競合を避けるようにしないでください。

私は一度だけあなたの高価なオブジェクトで初期化になるだろう単一ThreadLocalまたはスレッドのスタティックを使用している状況でどうなるのか。その後、スレッドプールスレッドが利用できるようになります。あなたのオブジェクトがMTAスレッドに微細であると仮定している

。私はそれがあなたの記事からのものだと思っている。

あまりにも多くのオブジェクトが作成されますと、プールが大きくなりすぎて、あなたがあまりにも多くのメモリを使用することが懸念されます。しかし、これが他のことを行う前に実際にそうであるかどうかを確認してください。これは簡単に実装できる非常に単純な戦略です。あなたが本当に必要な場合にのみ、より複雑になります。

Answer 2

何よりもまず、私は@briantylerに同意する：ThreadLocal<T>または静的フィールドのスレッドが何をしたいと考えられます。それを出発点にして、それがあなたのニーズを満たしていない場合は、他の選択肢も検討してください。

複雑で柔軟代替は、シングルトンオブジェクトプールです。その最も単純な形式では、あなたのプールの種類は次のようになります。あなたがプールとして、プリミティブクラスまたは構造体（すなわちObjectPool<MyComponent>）の観点タイプTを考えている場合

は

public sealed class ObjectPool<T> 
{ 
    private readonly ConcurrentQueue<T> __objects = new ConcurrentQueue<T>(); 
    private readonly Func<T> __factory; 

    public ObjectPool(Func<T> factory) 
    { 
     __factory = factory; 
    } 

    public T Get() 
    { 
     T obj; 
     return __objects.TryDequeue(out obj) ? obj : __factory(); 
    } 

    public void Return(T obj) 
    { 
     __objects.Enqueue(obj); 
    } 
} 

これはとても便利いないようです建てられた任意のスレッドのコントロールを持っていません。しかし、あなたはLazy<T>やTask<T>モナドのためのあなたのタイプTを代用し、正確に何をしたい得ることができます。

プールの初期化：

Func<Task<MyComponent>> factory =() => Task.Run(() => new MyComponent()); 
ObjectPool<Task<MyComponent>> pool = new ObjectPool<Task<MyComponent>>(factory); 

// "Pre-warm up" the pool with 16 concurrent tasks. 
// This starts the tasks on the thread pool and 
// returns immediately without blocking. 
for (int i = 0; i < 16; i++) { 
    pool.Return(pool.Get()); 
} 

使用法：

// Get a pooled task or create a new one. The task may 
// have already completed, in which case Result will 
// be available immediately. If the task is still 
// in flight, accessing its Result will block. 
Task<MyComponent> task = pool.Get(); 

try 
{ 
    MyComponent component = task.Result; // Alternatively you can "await task" 

    // Do something with component. 
} 
finally 
{ 
    pool.Return(task); 
} 

この方法はThreadLocalまたはスレッドの静的フィールドであなたのコンポーネントを維持するよりも複雑ですが、制限のような派手な何かをする必要がある場合プールされたインスタンスの数、プールの抽象化は非常に便利です。

public sealed class ObjectPool<T> 
{ 
    private readonly Queue<T> __objects; 

    public ObjectPool(IEnumerable<T> items) 
    { 
     __objects = new Queue<T>(items); 
    } 

    public T Get() 
    { 
     lock (__objects) 
     { 
      while (__objects.Count == 0) { 
       Monitor.Wait(__objects); 
      } 

      return __objects.Dequeue(); 
     } 
    } 

    public void Return(T obj) 
    { 
     lock (__objects) 
     { 
      __objects.Enqueue(obj); 

      Monitor.Pulse(__objects); 
     } 
    } 
}