啟動多項非同步工作並在它們完成時進行處理 (Visual Basic)
使用 Task.WhenAny,即可同時啟動多個工作,並在完成時逐一進行處理,而不是依啟動順序進行處理。
下列範例使用查詢來建立工作集合。 每項工作都會下載所指定網站的內容。 在 while 迴圈的的每個反覆運算中,等候的 WhenAny
呼叫會先傳回完成其下載的工作集合中的工作。 該工作會從集合中予以移除,並進行處理。 迴圈會重複進行,直到集合未包含其他工作為止。
注意
若要執行範例,您必須在電腦上安裝 Visual Studio 2012 或更新版本以及 .NET Framework 4.5 或更新版本。
下載範例
您可以從 Async Sample: Fine Tuning Your Application (非同步範例:微調應用程式) 下載完整 Windows Presentation Foundation (WPF) 專案,然後遵循下列步驟。
解壓縮您下載的檔案,然後啟動 Visual Studio。
在功能表列上,依序選擇 [檔案] 、[開啟舊檔] 及 [專案/方案] 。
在 [開啟專案] 對話方塊中,開啟保存已解壓縮之範例程式碼的資料夾,然後開啟 AsyncFineTuningVB 的方案 (.sln) 檔案。
在方案總管中,開啟 ProcessTasksAsTheyFinish 專案的捷徑功能表,然後選擇 [設定為啟始專案]。
選擇 F5 鍵以執行專案。
選擇 CTRL+F5 鍵以執行專案,而不進行偵錯。
執行專案數次,確認所下載的長度不一定會以相同的順序出現。
如果您不想要下載專案,可以檢閱本主題結尾的 MainWindow.xaml.vb 檔案。
建置範例
此範例會新增至在「當其中一項工作完成時,取消剩餘的非同步工作 (Visual Basic)」中開發的程式碼,並使用相同的 UI。
若要自行逐步建置範例,請遵循<下載範例>一節中的指示,但選擇 [CancelAfterOneTask] 作為 [啟始專案]。 將本主題中的變更新增至該專案中的 AccessTheWebAsync
方法。 變更會標上星號。
CancelAfterOneTask 專案已經包含一個查詢,這個查詢在執行時,會建立一組工作。 下列程式碼中的每個 ProcessURLAsync
呼叫都會傳回 TResult
為整數的 Task<TResult>。
Dim downloadTasksQuery As IEnumerable(Of Task(Of Integer)) =
From url In urlList Select ProcessURLAsync(url, client, ct)
在專案的 MainWindow.xaml.vb 檔案中,對 AccessTheWebAsync
方法進行下列變更。
套用 Enumerable.ToList 來執行查詢,而非 ToArray。
Dim downloadTasks As List(Of Task(Of Integer)) = downloadTasksQuery.ToList()
新增 while 迴圈,以對集合中的每個工作執行下列步驟。
等候
WhenAny
呼叫,識別集合中的第一個工作以完成其下載。Dim finishedTask As Task(Of Integer) = Await Task.WhenAny(downloadTasks)
從集合中移除該工作。
downloadTasks.Remove(finishedTask)
等候
ProcessURLAsync
呼叫所傳回的finishedTask
。finishedTask
變數是 Task<TResult>,其中TReturn
是整數。 工作已完成,但您等候它擷取所下載網站的長度,如下列範例所示。Dim length = Await finishedTask resultsTextBox.Text &= String.Format(vbCrLf & "Length of the downloaded website: {0}" & vbCrLf, length)
您應該執行專案數次,確認所下載的長度不一定會以相同的順序出現。
警告
您可以如這個範例所述在迴圈中使用 WhenAny
,以解決牽涉到少量工作的問題。 不過,如果您有大量的工作要處理,其他方法會更有效率。 如需詳細資訊和範例,請參閱Processing Tasks as they complete(在工作完成時加以處理)。
完整範例
下列程式碼是範例的 MainWindow.xaml.vb 檔案的完整文字。 星號會標記已針對此範例新增的項目。
請注意,您必須新增 System.Net.Http 的參考。
您可以從 Async Sample: Fine Tuning Your Application (非同步範例:微調應用程式) 下載專案。
' Add an Imports directive and a reference for System.Net.Http.
Imports System.Net.Http
' Add the following Imports directive for System.Threading.
Imports System.Threading
Class MainWindow
' Declare a System.Threading.CancellationTokenSource.
Dim cts As CancellationTokenSource
Private Async Sub startButton_Click(sender As Object, e As RoutedEventArgs)
' Instantiate the CancellationTokenSource.
cts = New CancellationTokenSource()
resultsTextBox.Clear()
Try
Await AccessTheWebAsync(cts.Token)
resultsTextBox.Text &= vbCrLf & "Downloads complete."
Catch ex As OperationCanceledException
resultsTextBox.Text &= vbCrLf & "Downloads canceled." & vbCrLf
Catch ex As Exception
resultsTextBox.Text &= vbCrLf & "Downloads failed." & vbCrLf
End Try
' Set the CancellationTokenSource to Nothing when the download is complete.
cts = Nothing
End Sub
' You can still include a Cancel button if you want to.
Private Sub cancelButton_Click(sender As Object, e As RoutedEventArgs)
If cts IsNot Nothing Then
cts.Cancel()
End If
End Sub
' Provide a parameter for the CancellationToken.
' Change the return type to Task because the method has no return statement.
Async Function AccessTheWebAsync(ct As CancellationToken) As Task
Dim client As HttpClient = New HttpClient()
' Call SetUpURLList to make a list of web addresses.
Dim urlList As List(Of String) = SetUpURLList()
' ***Create a query that, when executed, returns a collection of tasks.
Dim downloadTasksQuery As IEnumerable(Of Task(Of Integer)) =
From url In urlList Select ProcessURLAsync(url, client, ct)
' ***Use ToList to execute the query and start the download tasks.
Dim downloadTasks As List(Of Task(Of Integer)) = downloadTasksQuery.ToList()
' ***Add a loop to process the tasks one at a time until none remain.
While downloadTasks.Count > 0
' ***Identify the first task that completes.
Dim finishedTask As Task(Of Integer) = Await Task.WhenAny(downloadTasks)
' ***Remove the selected task from the list so that you don't
' process it more than once.
downloadTasks.Remove(finishedTask)
' ***Await the first completed task and display the results.
Dim length = Await finishedTask
resultsTextBox.Text &= String.Format(vbCrLf & "Length of the downloaded website: {0}" & vbCrLf, length)
End While
End Function
' Bundle the processing steps for a website into one async method.
Async Function ProcessURLAsync(url As String, client As HttpClient, ct As CancellationToken) As Task(Of Integer)
' GetAsync returns a Task(Of HttpResponseMessage).
Dim response As HttpResponseMessage = Await client.GetAsync(url, ct)
' Retrieve the website contents from the HttpResponseMessage.
Dim urlContents As Byte() = Await response.Content.ReadAsByteArrayAsync()
Return urlContents.Length
End Function
' Add a method that creates a list of web addresses.
Private Function SetUpURLList() As List(Of String)
Dim urls = New List(Of String) From
{
"https://msdn.microsoft.com",
"https://msdn.microsoft.com/library/hh290138.aspx",
"https://msdn.microsoft.com/library/hh290140.aspx",
"https://msdn.microsoft.com/library/dd470362.aspx",
"https://msdn.microsoft.com/library/aa578028.aspx",
"https://msdn.microsoft.com/library/ms404677.aspx",
"https://msdn.microsoft.com/library/ff730837.aspx"
}
Return urls
End Function
End Class
' Sample output:
' Length of the download: 226093
' Length of the download: 412588
' Length of the download: 175490
' Length of the download: 204890
' Length of the download: 158855
' Length of the download: 145790
' Length of the download: 44908
' Downloads complete.