0

不明な量のタスクを実行するアプリがあります。タスクがブロックされています (ネットワーク上で待機しています)。ビジー状態を維持するには複数のスレッドが必要です。

アイドル状態のときにタスクをプルするタスク スレッドとワーカー スレッドの巨大なリストを作成する簡単な方法はありますか? ATM タスクごとに新しいスレッドを開始するだけです。これは問題ありませんが、何らかの制御が必要なため、100 個のタスクがある場合、100 個のスレッドはありません。

4

2 に答える 2

2

扱っているネットワーク I/O クラスが Begin/End スタイルの非同期メソッドを公開すると仮定すると、必要なのは TPL TaskFactory.FromAsyncメソッドを使用することです。TPL TaskFactory.FromAsync とブロッキング メソッドを使用したタスクで説明されているように、FromAsync メソッドは、I/O が完了するのを待つだけでスレッドをビジー状態に保つのではなく、裏で非同期 I/O を使用します (これは実際には望んでいないことです)。 ）。

非同期 I/O が機能する方法は、I/O の結果が準備できたときにその結果を処理できるスレッドのプールがあるため、未処理の I/O が 100 ある場合でも、100 のスレッドがブロックされて待機することはありません。それらの I/O のために。プール全体が I/O 結果の処理でビジー状態になると、後続の結果は、スレッドが解放されて処理できるようになるまで、自動的にキューに入れられます。スレッドの巨大なプールをそのように待機させておくことは、スケーラビリティの災害です。スレッドは、アイドル状態を維持するための非常に高価なオブジェクトです。

于 2012-07-31T18:27:46.907 に答える
0

ここでは、スレッドプールを介して多くのスレッドを管理するためのmsdnサンプルを示します。

using System;

System.Threadingを使用します。

public class Fibonacci {public Fibonacci（int n、ManualResetEvent doneEvent）{_n = n; _doneEvent = doneEvent; }

// Wrapper method for use with thread pool.
public void ThreadPoolCallback(Object threadContext)
{
    int threadIndex = (int)threadContext;
    Console.WriteLine("thread {0} started...", threadIndex);
    _fibOfN = Calculate(_n);
    Console.WriteLine("thread {0} result calculated...", threadIndex);
    _doneEvent.Set();
}

// Recursive method that calculates the Nth Fibonacci number.
public int Calculate(int n)
{
    if (n <= 1)
    {
        return n;
    }

    return Calculate(n - 1) + Calculate(n - 2);
}

public int N { get { return _n; } }
private int _n;

public int FibOfN { get { return _fibOfN; } }
private int _fibOfN;

private ManualResetEvent _doneEvent;

}

public class ThreadPoolExample {static void Main（）{const int FibonacciCalculations = 10;

    // One event is used for each Fibonacci object
    ManualResetEvent[] doneEvents = new ManualResetEvent[FibonacciCalculations];
    Fibonacci[] fibArray = new Fibonacci[FibonacciCalculations];
    Random r = new Random();

    // Configure and launch threads using ThreadPool:
    Console.WriteLine("launching {0} tasks...", FibonacciCalculations);
    for (int i = 0; i < FibonacciCalculations; i++)
    {
        doneEvents[i] = new ManualResetEvent(false);
        Fibonacci f = new Fibonacci(r.Next(20,40), doneEvents[i]);
        fibArray[i] = f;
        ThreadPool.QueueUserWorkItem(f.ThreadPoolCallback, i);
    }

    // Wait for all threads in pool to calculation...
    WaitHandle.WaitAll(doneEvents);
    Console.WriteLine("All calculations are complete.");

    // Display the results...
    for (int i= 0; i<FibonacciCalculations; i++)
    {
        Fibonacci f = fibArray[i];
        Console.WriteLine("Fibonacci({0}) = {1}", f.N, f.FibOfN);
    }
}

}

于 2012-07-31T18:26:06.207 に答える