Megosztás a következőn keresztül:


Útmutató: Az Async útmutató kiterjesztése a Task.WhenAll (Visual Basic) használatával

A módszer használatával javíthatja az aszinkron megoldás teljesítményét az útmutatóban: A web elérése az Async és a Await (Visual Basic) használatával Task.WhenAll . Ez a módszer aszinkron módon több aszinkron műveletet vár, amelyek feladatgyűjteményként jelennek meg.

Előfordulhat, hogy az útmutatóban észrevette, hogy a webhelyek különböző sebességgel töltenek le. Néha az egyik webhely nagyon lassú, ami késlelteti az összes többi letöltést. Ha az útmutatóban beépített aszinkron megoldásokat futtatja, egyszerűen befejezheti a programot, ha nem szeretne várni, de jobb megoldás az lenne, ha az összes letöltést egyszerre indítaná el, és lehetővé tenné a gyorsabb letöltések folytatását anélkül, hogy a késleltetettre várna.

A Task.WhenAll módszert a feladatok gyűjteményére alkalmazod. Az alkalmazás WhenAll egyetlen olyan feladatot ad vissza, amely nem fejeződik be, amíg a gyűjtemény összes feladata be nem fejeződik. Úgy tűnik, hogy a feladatok párhuzamosan futnak, de további szálak nem jönnek létre. A feladatok bármilyen sorrendben elvégezhetők.

Fontos

Az alábbi eljárások az útmutatóban kifejlesztett aszinkron alkalmazások bővítményeit ismertetik : A web elérése az Async és a Await (Visual Basic) használatával. Az alkalmazásokat úgy fejlesztheti, hogy végrehajtja az útmutatót, vagy letölti a mintát a .NET mintaböngészőből. A példakód a SerialAsyncExample projektben található.

A példa futtatásához telepítve kell lennie a Visual Studio 2012 vagy újabb verziójának a számítógépre.

Task.WhenAll hozzáadása a GetURLContentsAsync megoldáshoz

  1. Adja hozzá a ProcessURLAsync metódust az első, az útmutatóban kifejlesztett alkalmazáshoz : A web elérése az Async és a Await (Visual Basic) használatával.

    • Ha letöltötte a kódot a fejlesztői kódmintákból, nyissa meg az AsyncWalkthrough projektet, majd adja hozzá ProcessURLAsync a MainWindow.xaml.vb fájlhoz.

    • Ha az útmutató végrehajtásával fejlesztette ki a kódot, adja hozzá ProcessURLAsync az alkalmazáshoz, amely tartalmazza a GetURLContentsAsync metódust. Az alkalmazás MainWindow.xaml.vb fájlja az első példa a "Teljes kód példák az útmutatóból" szakaszban.

    A ProcessURLAsync metódus az eredeti útmutatóban összevonja a For EachSumPageSizesAsync ciklus törzsében lévő műveleteket. A metódus aszinkron módon letölti egy adott webhely tartalmát bájttömbként, majd megjeleníti és visszaadja a bájttömb hosszát.

    Private Async Function ProcessURLAsync(url As String) As Task(Of Integer)
    
        Dim byteArray = Await GetURLContentsAsync(url)
        DisplayResults(url, byteArray)
        Return byteArray.Length
    End Function
    
  2. Az alábbi kód szerint kommentelje vagy törölje a For Each ciklust a SumPageSizesAsync fájlban.

    'Dim total = 0
    'For Each url In urlList
    
    '    Dim urlContents As Byte() = Await GetURLContentsAsync(url)
    
    '    ' The previous line abbreviates the following two assignment statements.
    
    '    ' GetURLContentsAsync returns a task. At completion, the task
    '    ' produces a byte array.
    '    'Dim getContentsTask As Task(Of Byte()) = GetURLContentsAsync(url)
    '    'Dim urlContents As Byte() = Await getContentsTask
    
    '    DisplayResults(url, urlContents)
    
    '    ' Update the total.
    '    total += urlContents.Length
    'Next
    
  3. Feladatgyűjtemény létrehozása. Az alábbi kód egy lekérdezést határoz meg, amely a ToArray metódus végrehajtásával olyan feladatgyűjteményt hoz létre, amely letölti az egyes webhelyek tartalmát. A feladatok a lekérdezés kiértékelésekor kezdődnek.

    Adja hozzá a következő kódot a metódushoz SumPageSizesAsync a deklaráció urlListután.

    ' Create a query.
    Dim downloadTasksQuery As IEnumerable(Of Task(Of Integer)) =
        From url In urlList Select ProcessURLAsync(url)
    
    ' Use ToArray to execute the query and start the download tasks.
    Dim downloadTasks As Task(Of Integer)() = downloadTasksQuery.ToArray()
    
  4. Alkalmazza Task.WhenAll a feladatok gyűjteményére, downloadTasks. Task.WhenAll Egyetlen feladatot ad vissza, amely akkor fejeződik be, amikor a feladatgyűjtemény összes tevékenysége befejeződött.

    Az alábbi példában a Await kifejezés a WhenAll által visszaadott egyetlen feladat befejezésére vár. A kifejezés egész számok tömbjeként értékeli ki, ahol minden egész szám egy letöltött webhely hossza. Adja hozzá a következő kódot SumPageSizesAsyncaz előző lépésben hozzáadott kód után.

    ' Await the completion of all the running tasks.
    Dim lengths As Integer() = Await Task.WhenAll(downloadTasks)
    
    '' The previous line is equivalent to the following two statements.
    'Dim whenAllTask As Task(Of Integer()) = Task.WhenAll(downloadTasks)
    'Dim lengths As Integer() = Await whenAllTask
    
  5. Végül a Sum módszerrel kiszámíthatja az összes webhely hosszának összegét. Adja hozzá az alábbi sort SumPageSizesAsync-hoz.

    Dim total = lengths.Sum()
    

Task.WhenAll hozzáadása a HttpClient.GetByteArrayAsync megoldáshoz

  1. Adja hozzá a következő verziót ProcessURLAsync a második, az útmutatóban kifejlesztett alkalmazáshoz : A webes hozzáférés az Async és a Await (Visual Basic) használatával.

    • Ha letöltötte a kódot a fejlesztői kódmintákból, nyissa meg a AsyncWalkthrough_HttpClient projektet, majd adja hozzá ProcessURLAsync a MainWindow.xaml.vb fájlhoz.

    • Ha az útmutató végigkövetésével fejlesztette ki a kódot, adja hozzá a ProcessURLAsync metódust használó alkalmazáshoz a HttpClient.GetByteArrayAsync-t. Az alkalmazás MainWindow.xaml.vb fájlja a második példa a "Teljes kód példák az útmutatóból" szakaszban.

    A ProcessURLAsync metódus az eredeti útmutatóban összevonja a For EachSumPageSizesAsync ciklus törzsében lévő műveleteket. A metódus aszinkron módon letölti egy adott webhely tartalmát bájttömbként, majd megjeleníti és visszaadja a bájttömb hosszát.

    Az előző eljárásban alkalmazott ProcessURLAsync módszerrel szembeni egyetlen különbség a HttpClient példány használata, client.

    Private Async Function ProcessURLAsync(url As String, client As HttpClient) As Task(Of Integer)
    
        Dim byteArray = Await client.GetByteArrayAsync(url)
        DisplayResults(url, byteArray)
        Return byteArray.Length
    End Function
    
  2. Az alábbi kód szerint kommentelje vagy törölje a For Each ciklust a SumPageSizesAsync fájlban.

    'Dim total = 0
    'For Each url In urlList
    '    ' GetByteArrayAsync returns a task. At completion, the task
    '    ' produces a byte array.
    '    Dim urlContents As Byte() = Await client.GetByteArrayAsync(url)
    
    '    ' The following two lines can replace the previous assignment statement.
    '    'Dim getContentsTask As Task(Of Byte()) = client.GetByteArrayAsync(url)
    '    'Dim urlContents As Byte() = Await getContentsTask
    
    '    DisplayResults(url, urlContents)
    
    '    ' Update the total.
    '    total += urlContents.Length
    'Next
    
  3. Határozzon meg egy lekérdezést , amely a metódus végrehajtásával ToArray olyan feladatgyűjteményt hoz létre, amely letölti az egyes webhelyek tartalmát. A feladatok a lekérdezés kiértékelésekor kezdődnek.

    Adja hozzá a következő kódot a metódushoz SumPageSizesAsync a client és urlList deklarációja után.

    ' Create a query.
    Dim downloadTasksQuery As IEnumerable(Of Task(Of Integer)) =
        From url In urlList Select ProcessURLAsync(url, client)
    
    ' Use ToArray to execute the query and start the download tasks.
    Dim downloadTasks As Task(Of Integer)() = downloadTasksQuery.ToArray()
    
  4. Ezután alkalmazza Task.WhenAll a tevékenységek gyűjteményére. downloadTasks Task.WhenAll Egyetlen feladatot ad vissza, amely akkor fejeződik be, amikor a feladatgyűjtemény összes tevékenysége befejeződött.

    Az alábbi példában a Await kifejezés a WhenAll által visszaadott egyetlen feladat befejezésére vár. Ha elkészült, a Await kifejezés egész számokat tartalmazó tömbre lesz kiértékelve, ahol minden egész szám egy letöltött webhely hossza. Adja hozzá a következő kódot SumPageSizesAsyncaz előző lépésben hozzáadott kód után.

    ' Await the completion of all the running tasks.
    Dim lengths As Integer() = Await Task.WhenAll(downloadTasks)
    
    '' The previous line is equivalent to the following two statements.
    'Dim whenAllTask As Task(Of Integer()) = Task.WhenAll(downloadTasks)
    'Dim lengths As Integer() = Await whenAllTask
    
  5. Végül használja a Sum módszert az összes webhely hosszának összegének lekéréséhez. Adja hozzá az alábbi sort SumPageSizesAsync-hoz.

    Dim total = lengths.Sum()
    

A Task.WhenAll megoldások tesztelése

Bármelyik megoldáshoz válassza az F5 billentyűt a program futtatásához, majd válassza a Start gombot. A kimenetnek az aszinkron megoldások kimenetéhez kell hasonlítania az útmutatóban: A web elérése az Async és a Await (Visual Basic) használatával. Figyelje meg azonban, hogy a webhelyek minden alkalommal eltérő sorrendben jelennek meg.

1. példa

Az alábbi kód a projekt bővítményeit mutatja be, amelyek a GetURLContentsAsync módszerrel töltik le a tartalmat a weből.

' Add the following Imports statements, and add a reference for System.Net.Http.
Imports System.Net.Http
Imports System.Net
Imports System.IO

Class MainWindow

    Async Sub startButton_Click(sender As Object, e As RoutedEventArgs) Handles startButton.Click

        resultsTextBox.Clear()

        ' One-step async call.
        Await SumPageSizesAsync()

        '' Two-step async call.
        'Dim sumTask As Task = SumPageSizesAsync()
        'Await sumTask

        resultsTextBox.Text &= vbCrLf & "Control returned to button1_Click."
    End Sub

    Private Async Function SumPageSizesAsync() As Task

        ' Make a list of web addresses.
        Dim urlList As List(Of String) = SetUpURLList()

        ' Create a query.
        Dim downloadTasksQuery As IEnumerable(Of Task(Of Integer)) =
            From url In urlList Select ProcessURLAsync(url)

        ' Use ToArray to execute the query and start the download tasks.
        Dim downloadTasks As Task(Of Integer)() = downloadTasksQuery.ToArray()

        ' You can do other work here before awaiting.

        ' Await the completion of all the running tasks.
        Dim lengths As Integer() = Await Task.WhenAll(downloadTasks)

        '' The previous line is equivalent to the following two statements.
        'Dim whenAllTask As Task(Of Integer()) = Task.WhenAll(downloadTasks)
        'Dim lengths As Integer() = Await whenAllTask

        Dim total = lengths.Sum()

        'Dim total = 0
        'For Each url In urlList

        '    Dim urlContents As Byte() = Await GetURLContentsAsync(url)

        '    ' The previous line abbreviates the following two assignment statements.

        '    ' GetURLContentsAsync returns a task. At completion, the task
        '    ' produces a byte array.
        '    'Dim getContentsTask As Task(Of Byte()) = GetURLContentsAsync(url)
        '    'Dim urlContents As Byte() = Await getContentsTask

        '    DisplayResults(url, urlContents)

        '    ' Update the total.
        '    total += urlContents.Length
        'NextNext

        ' Display the total count for all of the web addresses.
        resultsTextBox.Text &= String.Format(vbCrLf & vbCrLf &
                                             "Total bytes returned:  {0}" & vbCrLf, total)
    End Function

    Private Function SetUpURLList() As List(Of String)

        Dim urls = New List(Of String) From
            {
                "https://msdn.microsoft.com",
                "https://msdn.microsoft.com/library/hh290136.aspx",
                "https://msdn.microsoft.com/library/ee256749.aspx",
                "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

    ' The actions from the foreach loop are moved to this async method.
    Private Async Function ProcessURLAsync(url As String) As Task(Of Integer)

        Dim byteArray = Await GetURLContentsAsync(url)
        DisplayResults(url, byteArray)
        Return byteArray.Length
    End Function

    Private Async Function GetURLContentsAsync(url As String) As Task(Of Byte())

        ' The downloaded resource ends up in the variable named content.
        Dim content = New MemoryStream()

        ' Initialize an HttpWebRequest for the current URL.
        Dim webReq = CType(WebRequest.Create(url), HttpWebRequest)

        ' Send the request to the Internet resource and wait for
        ' the response.
        Using response As WebResponse = Await webReq.GetResponseAsync()
            ' Get the data stream that is associated with the specified URL.
            Using responseStream As Stream = response.GetResponseStream()
                ' Read the bytes in responseStream and copy them to content.
                ' CopyToAsync returns a Task, not a Task<T>.
                Await responseStream.CopyToAsync(content)
            End Using
        End Using

        ' Return the result as a byte array.
        Return content.ToArray()
    End Function

    Private Sub DisplayResults(url As String, content As Byte())

        ' Display the length of each website. The string format
        ' is designed to be used with a monospaced font, such as
        ' Lucida Console or Global Monospace.
        Dim bytes = content.Length
        ' Strip off the "https://".
        Dim displayURL = url.Replace("https://", "")
        resultsTextBox.Text &= String.Format(vbCrLf & "{0,-58} {1,8}", displayURL, bytes)
    End Sub

End Class

2. példa

Az alábbi kód a projekt bővítményeit mutatja be, amelyek metódust HttpClient.GetByteArrayAsync használnak a tartalom webes letöltésére.

' Add the following Imports statements, and add a reference for System.Net.Http.
Imports System.Net.Http
Imports System.Net
Imports System.IO

Class MainWindow

    Async Sub startButton_Click(sender As Object, e As RoutedEventArgs) Handles startButton.Click

        resultsTextBox.Clear()

        '' One-step async call.
        Await SumPageSizesAsync()

        '' Two-step async call.
        'Dim sumTask As Task = SumPageSizesAsync()
        'Await sumTask

        resultsTextBox.Text &= vbCrLf & "Control returned to button1_Click."
    End Sub

    Private Async Function SumPageSizesAsync() As Task

        ' Declare an HttpClient object and increase the buffer size. The
        ' default buffer size is 65,536.
        Dim client As HttpClient =
            New HttpClient() With {.MaxResponseContentBufferSize = 1000000}

        ' Make a list of web addresses.
        Dim urlList As List(Of String) = SetUpURLList()

        ' Create a query.
        Dim downloadTasksQuery As IEnumerable(Of Task(Of Integer)) =
            From url In urlList Select ProcessURLAsync(url, client)

        ' Use ToArray to execute the query and start the download tasks.
        Dim downloadTasks As Task(Of Integer)() = downloadTasksQuery.ToArray()

        ' You can do other work here before awaiting.

        ' Await the completion of all the running tasks.
        Dim lengths As Integer() = Await Task.WhenAll(downloadTasks)

        '' The previous line is equivalent to the following two statements.
        'Dim whenAllTask As Task(Of Integer()) = Task.WhenAll(downloadTasks)
        'Dim lengths As Integer() = Await whenAllTask

        Dim total = lengths.Sum()

        ''<snippet7>
        'Dim total = 0
        'For Each url In urlList
        '    ' GetByteArrayAsync returns a task. At completion, the task
        '    ' produces a byte array.
        '    '<snippet31>
        '    Dim urlContents As Byte() = Await client.GetByteArrayAsync(url)
        '    '</snippet31>

        '    ' The following two lines can replace the previous assignment statement.
        '    'Dim getContentsTask As Task(Of Byte()) = client.GetByteArrayAsync(url)
        '    'Dim urlContents As Byte() = Await getContentsTask

        '    DisplayResults(url, urlContents)

        '    ' Update the total.
        '    total += urlContents.Length
        'NextNext

        ' Display the total count for all of the web addresses.
        resultsTextBox.Text &= String.Format(vbCrLf & vbCrLf &
                                             "Total bytes returned:  {0}" & vbCrLf, total)
    End Function

    Private Function SetUpURLList() As List(Of String)

        Dim urls = New List(Of String) From
            {
                "https://www.msdn.com",
                "https://msdn.microsoft.com/library/hh290136.aspx",
                "https://msdn.microsoft.com/library/ee256749.aspx",
                "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

    Private Async Function ProcessURLAsync(url As String, client As HttpClient) As Task(Of Integer)

        Dim byteArray = Await client.GetByteArrayAsync(url)
        DisplayResults(url, byteArray)
        Return byteArray.Length
    End Function

    Private Sub DisplayResults(url As String, content As Byte())

        ' Display the length of each website. The string format
        ' is designed to be used with a monospaced font, such as
        ' Lucida Console or Global Monospace.
        Dim bytes = content.Length
        ' Strip off the "https://".
        Dim displayURL = url.Replace("https://", "")
        resultsTextBox.Text &= String.Format(vbCrLf & "{0,-58} {1,8}", displayURL, bytes)
    End Sub

End Class

Lásd még