我正在创建一个包含5个任务的数组,调用字符串返回方法"Essen"
tasks[0] = new Task(() => Philosoph.Essen("1", gabeln[2], gabeln[1]));
tasks[1] = new Task(() => Philosoph.Essen("2", gabeln[3], gabeln[2]));
tasks[2] = new Task(() => Philosoph.Essen("3", gabeln[4], gabeln[3]));
tasks[3] = new Task(() => Philosoph.Essen("4", gabeln[5], gabeln[4]));
tasks[4] = new Task(() => Philosoph.Essen("5", gabeln[1], gabeln[5]));
然后我开始使用并行这些任务。ForEach
Parallel.ForEach(tasks, t =>
{
t.Start();
});
Task.WaitAll(tasks);
方法Essen返回字符串
static public string Essen(String philosoph, String linkeGabel, String rechteGabel)
{
lock (linkeGabel)
{
lock (rechteGabel)
{
return ("Philosoph " + philosoph + "isst mit: " + linkeGabel + ", " + rechteGabel );
}
}
}
如何处理Essen()- 5个并行处理中的每一个的返回值?我想把这些返回值写入一个列表框…
您使用ContinueWhenAll
:
// once tasks are started
TaskFactory.ContinueWhenAll(
tasks,
results =>
{
foreach (var t in results)
{
if (t.IsCompleted)
listBox.Items.Add(t.Result);
}
},
cts.Token,
TaskContinuationOptions.None,
TaskScheduler.FromCurrentSynchronizationContext());
确保为ListBox
使用正确的调度程序。此外,您需要确保您"观察"任何可能发生的Task<TResult>.Exception
(即,如果t.IsFaulted
检查t.Exception
)。
然而,当前你的任务没有定义为返回任何东西。您需要将它们的定义更改为Task<TResult>
:
// will use the return type of Philosoph.Essen, which is string
// Task<string>[] tasks;
var tasks = new []
{
Task.Factory.StartNew(() => Philosoph.Essen("1", gabeln[2], gabeln[1])),
Task.Factory.StartNew(() => Philosoph.Essen("2", gabeln[3], gabeln[2])),
Task.Factory.StartNew(() => Philosoph.Essen("3", gabeln[4], gabeln[3])),
Task.Factory.StartNew(() => Philosoph.Essen("4", gabeln[5], gabeln[4])),
Task.Factory.StartNew(() => Philosoph.Essen("5", gabeln[1], gabeln[5])),
};