好像由于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) { ... }
}