好像由于IEnumerable的状态不一致而导致线程错误。具体来说,是List<T>

这是我的工作流程:

List<string> IDs = getIDs();
RunTask(IDs);
RunTask(IDs);

public void RunTask(List<string> IDs)
{
    TaskScheduler scheduler = new TaskScheduler();
    TaskFactory factory = new TaskFactory(scheduler);
    var tasks = IDs.Select(name => factory.StartNew(() => action(name))).ToArray();
    Task.WaitAll(tasks);
}

我的WaitAll()通话出现一般错误。

我的想法是,我得到了某种不同步的IEnumerator,我需要通过List复制Array.CopyTo(),然后将其传递到我的多个线程中。

这是我的异常(exception):
Error: One or more errors occurred.
One or more errors occurred.
at System.Threading.Tasks.Task.WaitAll(Task[] tasks, Int32 millisecondsTimeout, CancellationToken cancellationToken)
at System.Threading.Tasks.Task.WaitAll(Task[] tasks, Int32 millisecondsTimeout)
at System.Threading.Tasks.Task.WaitAll(Task[] tasks)

关于这个问题有什么想法吗?

最佳答案

我不认为这是线程错误-只要每个任务都不会修改IDs列表,它应该是安全的。如果任何等待的任务抛出异常或被取消,则Task.WaitAll()会引发AggregateException

您可以访问异常上的InnerExceptions来查看错误是什么。

try
{
    Task.WaitAll(tasks);
}
catch(AggregateException ex)
{
    foreach(Exception in ex.InnerExceptions) { ... }
}

10-07 19:43
查看更多