0

我有一个应用程序承担未知数量的任务。该任务正在阻塞（他们在网络上等待）我需要多个线程来保持忙碌。

有没有一种简单的方法可以让我拥有一个庞大的任务和工作线程列表，当它们空闲时它们会拉出任务？ATM 我只是为每个任务启动一个新线程，这很好，但我想要一些控制，所以如果有 100 个任务，我就没有 100 个线程。

4

2 回答 2

2

假设您正在处理的网络 I/O 类公开 Begin/End 样式的异步方法，那么您想要做的是使用 TPL TaskFactory.FromAsync方法。正如TPL TaskFactory.FromAsync vs Tasks with blocking methods中所述，FromAsync 方法将在幕后使用异步 I/O，而不是让线程忙于等待 I/O 完成（这实际上不是您想要的）。

异步 I/O 的工作方式是您有一个线程池，可以在结果准备好时处理I/O 的结果，因此如果您有 100 个未完成的 I/O，则不会有 100 个线程阻塞等待对于那些 I/O。当整个池都忙于处理 I/O 结果时，后续结果会自动排队，直到有线程空闲来处理它们。像这样保持大量线程等待是可伸缩性灾难 - 线程是非常昂贵的对象，需要保持空闲状态。

于 2012-07-31T18:27:46.907 回答
0

这是一个通过线程池管理多个线程的 msdn 示例：

using System;

使用 System.Threading；

公共类斐波那契{公共斐波那契（int n，ManualResetEvent doneEvent）{_n = n; _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;

}

公共类 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 回答