介紹一種基于任務(wù)的異步模式TAP

TAP 是基于任務(wù)的異步模式，在 .NET Framework 4 中引入。TAP 是 APM 和 EAP，是推薦的模式模式。

異步/等待

async 和 是為異步編程的語法，方便我們在之前編寫異步代碼，有辦法會等待，但不會阻止。

public async Task DoSomethingAsync()
{
// For this example, we`re just going to (aynchronously) wait 100ms.
await Task.Delay(100);
}

對于調(diào)用的方法，等一個方法結(jié)束后會顯示，等今天今天繼續(xù)執(zhí)行顯示代碼。、

等待的

await 就像是一元操作符，接收一個參數(shù) - awaitable。Task 和 Task 都是這樣的類型。

public async Task NewStuffAsync()
{
// Use await and have fun with the new stuff.
await ...
}
public Task MyOldTaskParallelLibraryCode()
{
// Note that this is not an async method, so we can`t use await in here.
...
}
public async Task ComposeAsync()
{
// We can await Tasks, regardless of where they come from.
await NewStuffAsync();
await MyOldTaskParallelLibraryCode();
}
Task.Yield()
await Task.Yield() 異步強制完成方法，可以來讓我們的異步方法執(zhí)行。 Yield() ，讓其他調(diào)度需要的任務(wù)，隨后完成該任務(wù)更替。

static async Task Process()
{
await Task.Yield();

var tcs = new TaskCompletionSource();

Task.Run(() =>
{
Thread.Sleep(1000);
tcs.SetResult(true);
});

tcs.Task.Wait();
}

我不著急，我到后面再去其他任務(wù)去，你先去處理吧。其實是利用等待線程的切換。

任務(wù).配置等待

在這種情況下，某種方法結(jié)束后可以繼續(xù)執(zhí)行當(dāng)前的回復(fù)任務(wù)。

await someTask.ConfigureAwait(continueOnCapturedContext:false);
CancellationTokenSource
從 .NET Framework 4 開始，TAP 方法支持取消操作。

var cts = new CancellationTokenSource();
string result = await DownloadStringTaskAsync(url, cts.Token);
… // at some point later, potentially on another thread
cts.Cancel();

// 取消多個異步調(diào)用
var cts = new CancellationTokenSource();
IList results = await Task.WhenAll(from url in urls select DownloadStringTaskAsync(url, cts.Token));
// at some point later, potentially on another thread
…
cts.Cancel();

進步

通過進度可以遠程監(jiān)控方法的執(zhí)行。

private async void btnDownload_Click(object sender, RoutedEventArgs e)
{
btnDownload.IsEnabled = false;
try
{
txtResult.Text = await DownloadStringTaskAsync(txtUrl.Text,
new Progress(p => pbDownloadProgress.Value = p));
}
finally { btnDownload.IsEnabled = true; }
}

任務(wù)運行

Task.Run() 可以很方便地執(zhí)行任務(wù)。

public async void button1_Click(object sender, EventArgs e)
{
// 默認(rèn)恢復(fù)上下文
textBox1.Text = await Task.Run(() =>
{
// … do compute-bound work here
return answer;
});
}

public async void button1_Click(object sender, EventArgs e)
{
// 內(nèi)部使用 await
pictureBox1.Image = await Task.Run(async() =>
{
using(Bitmap bmp1 = await DownloadFirstImageAsync())
using(Bitmap bmp2 = await DownloadSecondImageAsync())
return Mashup(bmp1, bmp2);
});
}
任務(wù).FromResult
Task.FromResult 使用創(chuàng)建一個帶返回值的，已完成的任務(wù)。

public Task GetValueAsync(string key)
{
int cachedValue;
return TryGetCachedValue(out cachedValue) ?
Task.FromResult(cachedValue) : // 如果本地有緩存，直接以同步的方式獲?。ǖ祷氐氖钱惒浇Y(jié)果）
GetValueAsyncInternal(); // 如果本地沒有key對應(yīng)的緩存，則異步從遠端獲取
}
// 異步方法從遠端獲取緩存
private async Task GetValueAsyncInternal(string key)
{
…
}

任務(wù).WhenAll

完成異步 異步操作的。

Task [] asyncOps = (from addr in addrs select SendMailAsync(addr)).ToArray();
try
{
await Task.WhenAll(asyncOps);
}
catch(Exception exc)
{
foreach(Task faulted in asyncOps.Where(t => t.IsFaulted))
{
… // work with faulted and faulted.Exception
}
}

Task.WhenAny

一次異步操作中，第一個異步操作完成時返回。

1. 可以同時進行多個相同的異步操作，同時進行選擇完成的那個

// 從多個行情源處獲取行情，使用最快的那個
var cts = new CancellationTokenSource();
var recommendations = new List>()
{
GetBuyRecommendation1Async(symbol, cts.Token),
GetBuyRecommendation2Async(symbol, cts.Token),
GetBuyRecommendation3Async(symbol, cts.Token)
};

Task recommendation = await Task.WhenAny(recommendations);
cts.Cancel(); // 取消剩余任務(wù)
if (await recommendation) BuyStock(symbol);
1.多個任務(wù)交叉進行（每完成一個就處理一個）

List> imageTasks =
(from imageUrl in urls select GetBitmapAsync(imageUrl)
.ContinueWith(t => ConvertImage(t.Result)).ToList();
while(imageTasks.Count > 0)
{
try
{
Task imageTask = await Task.WhenAny(imageTasks);
imageTasks.Remove(imageTask);

Bitmap image = await imageTask;
panel.AddImage(image);
}
catch{}
}

任務(wù)延遲

在任意方法中確定任務(wù)?？梢院?Task.WhenAny ，Task.WhenAll 結(jié)合使用以暫態(tài)調(diào)用處理。

public async void btnDownload_Click(object sender, EventArgs e)
{
btnDownload.Enabled = false;
try
{
Task download = GetBitmapAsync(url);
if (download == await Task.WhenAny(download, Task.Delay(3000)))
{
Bitmap bmp = await download;
pictureBox.Image = bmp;
status.Text = "Downloaded";
}
else
{
pictureBox.Image = null;
status.Text = "Timed out";
var ignored = download.ContinueWith(
t => Trace("Task finally completed"));
}
}
finally { btnDownload.Enabled = true; }
}



審核編輯：劉清