当在工作线程上调用的方法需要在 UI 线程上运行代码并等待它完成后再做其他事情时,可以这样完成:
public int RunOnUi(Func<int> f)
{
int res = Application.Current.Dispatcher.Invoke(f);
return res;
}
但是如果我想用任务来做呢? RunOnUi 方法有没有办法创建一个在 UI 上启动的任务并返回它,以便调用者(在工作线程上运行)可以等待它?适合以下签名的内容:public Task<int> StartOnUi(Func<int> f)
?
一种方法如下:
public Task<int> RunOnUi(Func<int> f)
{
var task = new Task<int>(f);
task.Start(_scheduler);
return task;
}
在这里,假设_schduler
持有 ui TaskScheduler
.但是我不太习惯创建“冷”任务并使用 start 方法来运行它们。这是“推荐的”方法还是有更优雅的方法?
最佳答案
只需使用 InvokeAsync
而不是 Invoke
然后返回 Task<int>
在 DispatcherOperation<int>
里面函数返回。
//Coding conventions say async functions should end with the word Async.
public Task<int> RunOnUiAsync(Func<int> f)
{
var dispatcherOperation = Application.Current.Dispatcher.InvokeAsync(f);
return dispatcherOperation.Task;
}
如果您无法访问 .NET 4.5,情况会稍微复杂一些。您将需要使用 BeginInvoke
和一个 TaskCompletionSource
包装 DispaterOperation
那BeginInvoke
返回
public Task<int> RunOnUi(Func<int> f)
{
var operation = Application.Current.Dispatcher.BeginInvoke(f);
var tcs = new TaskCompletionSource<int>();
operation.Aborted += (sender, args) => tcs.TrySetException(new SomeExecptionHere());
operation.Completed += (sender, args) => tcs.TrySetResult((int)operation.Result);
//The operation may have already finished and this check accounts for
//the race condition where neither of the events will ever be called
//because the events where raised before you subscribed.
var status = operation.Status;
if (status == DispatcherOperationStatus.Completed)
{
tcs.TrySetResult((int)operation.Result);
}
else if (status == DispatcherOperationStatus.Aborted)
{
tcs.TrySetException(new SomeExecptionHere());
}
return tcs.Task;
}
关于c# - 在 UI 线程上创建和启动任务,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/28194943/