ThreadPool.QueueUserWorkItem Metódus

Definíció

Névtér:

System.Threading

Szerelvények:

netstandard.dll, System.Threading.ThreadPool.dll

Végrehajtási metódus várólistája. A metódus akkor hajtja végre, ha egy szálkészlet szála elérhetővé válik.

Túlterhelések

Name	Description
QueueUserWorkItem(WaitCallback)	Végrehajtási metódus várólistája. A metódus akkor hajtja végre, ha egy szálkészlet szála elérhetővé válik.
QueueUserWorkItem(WaitCallback, Object)	Várólistára helyez egy végrehajtási metódust, és megadja a metódus által használandó adatokat tartalmazó objektumot. A metódus akkor hajtja végre, ha egy szálkészlet szála elérhetővé válik.
QueueUserWorkItem<TState>(Action<TState>, TState, Boolean)	Várólistára állítja a Action<T> meghatalmazott által a végrehajtáshoz megadott metódust, és megadja a metódus által használandó adatokat. A metódus akkor hajtja végre, ha egy szálkészlet szála elérhetővé válik.

QueueUserWorkItem(WaitCallback)

Forrás:

ThreadPoolWorkQueue.cs

Végrehajtási metódus várólistája. A metódus akkor hajtja végre, ha egy szálkészlet szála elérhetővé válik.

public:
 static bool QueueUserWorkItem(System::Threading::WaitCallback ^ callBack);

public static bool QueueUserWorkItem(System.Threading.WaitCallback callBack);

static member QueueUserWorkItem : System.Threading.WaitCallback -> bool

Public Shared Function QueueUserWorkItem (callBack As WaitCallback) As Boolean

Paraméterek

callBack

WaitCallback

A WaitCallback végrehajtandó metódust jelképező.

Válaszok

Boolean

true ha a metódus sikeresen várólistára van állítva; NotSupportedException akkor kerül sorba, ha a munkaelemet nem lehetett várólistára tenni.

Kivételek

ArgumentNullException

callBack az null.

NotSupportedException

A rendszer üzemelteti a közös nyelvi futtatókörnyezetet (CLR), és a gazdagép nem támogatja ezt a műveletet.

Példák

Az alábbi példa a metódus túlterhelését QueueUserWorkItem(WaitCallback) használja egy feladat várólistára helyezéséhez, amelyet a ThreadProc metódus jelöl, amikor egy szál elérhetővé válik. Ez a túlterhelés nem tartalmaz tevékenységinformációt. Ezért a metódus számára ThreadProc elérhető információk csak arra az objektumra korlátozódnak, amelyhez a metódus tartozik.

using System;
using System.Threading;

public class Example 
{
    public static void Main() 
    {
        // Queue the task.
        ThreadPool.QueueUserWorkItem(ThreadProc);
        Console.WriteLine("Main thread does some work, then sleeps.");
        Thread.Sleep(1000);

        Console.WriteLine("Main thread exits.");
    }

    // This thread procedure performs the task.
    static void ThreadProc(Object stateInfo) 
    {
        // No state object was passed to QueueUserWorkItem, so stateInfo is null.
        Console.WriteLine("Hello from the thread pool.");
    }
}
// The example displays output like the following:
//       Main thread does some work, then sleeps.
//       Hello from the thread pool.
//       Main thread exits.

Imports System.Threading

Public Module Example
    Public Sub Main()
        ' Queue the work for execution.
        ThreadPool.QueueUserWorkItem(AddressOf ThreadProc)
        
        Console.WriteLine("Main thread does some work, then sleeps.")

        Thread.Sleep(1000)

        Console.WriteLine("Main thread exits.")
    End Sub

    ' This thread procedure performs the task.
    Sub ThreadProc(stateInfo As Object)
        ' No state object was passed to QueueUserWorkItem, so stateInfo is null.
        Console.WriteLine("Hello from the thread pool.")
    End Sub
End Module
' The example displays output like the following:
'       Main thread does some work, then sleeps.
'       Hello from the thread pool.
'       Main thread exits.

Megjegyzések

Az üzenetsoros metódus által igényelt adatokat annak az osztálynak a példánymezőibe helyezheti, amelyben a metódus definiálva van, vagy használhatja azt a QueueUserWorkItem(WaitCallback, Object) túlterhelést, amely elfogadja a szükséges adatokat tartalmazó objektumot.

Note

Visual Basic felhasználók kihagyhatják a WaitCallback konstruktort, és egyszerűen használhatják a AddressOf operátort a visszahívási módszer QueueUserWorkItem. Visual Basic automatikusan meghívja a megfelelő delegált konstruktort.

A Thread.CurrentPrincipal tulajdonságértéket a rendszer a QueueUserWorkItem metódussal várólistára helyezett feldolgozói szálakra propagálja.

Lásd még

• A felügyelt szálkészlet

QueueUserWorkItem(WaitCallback, Object)

Forrás:

ThreadPoolWorkQueue.cs

Várólistára helyez egy végrehajtási metódust, és megadja a metódus által használandó adatokat tartalmazó objektumot. A metódus akkor hajtja végre, ha egy szálkészlet szála elérhetővé válik.

public:
 static bool QueueUserWorkItem(System::Threading::WaitCallback ^ callBack, System::Object ^ state);

public static bool QueueUserWorkItem(System.Threading.WaitCallback callBack, object? state);

static member QueueUserWorkItem : System.Threading.WaitCallback * obj -> bool

Public Shared Function QueueUserWorkItem (callBack As WaitCallback, state As Object) As Boolean

Paraméterek

callBack

WaitCallback

A WaitCallback végrehajtandó metódust jelképező.

state

Object

A metódus által használandó adatokat tartalmazó objektum.

Válaszok

Boolean

true ha a metódus sikeresen várólistára van állítva; NotSupportedException akkor kerül sorba, ha a munkaelemet nem lehetett várólistára tenni.

Kivételek

NotSupportedException

A rendszer üzemelteti a közös nyelvi futtatókörnyezetet (CLR), és a gazdagép nem támogatja ezt a műveletet.

ArgumentNullException

callBack az null.

Példák

Az alábbi példa a .NET szálkészletet használja a Fibonacci eredmény kiszámításához öt 20 és 40 közötti számra. Minden Fibonacci eredményt az Fibonacci osztály jelöl, amely egy olyan metódust ThreadPoolCallback biztosít, amely elvégzi a számítást. Létrejön egy objektum, amely az egyes Fibonacci értékeket jelöli, és a ThreadPoolCallback metódust átadja QueueUserWorkItema rendszer, amely hozzárendel egy elérhető szálat a készletben a metódus végrehajtásához.

Mivel minden Fibonacci objektum félig véletlenszerű értéket kap a számításhoz, és mivel minden szál verseng a processzoridőért, nem tudhatja előre, hogy mennyi ideig tart mind az öt eredmény kiszámítása. Ezért minden Fibonacci objektum az osztály egy példányát adja át az ManualResetEvent építés során. Minden objektum jelzi a megadott eseményobjektumot a számítás befejezésekor, ami lehetővé teszi, hogy az elsődleges szál blokkolja a végrehajtást WaitAll mind az öt Fibonacci objektum eredményének kiszámításáig. A Main metódus ezután megjeleníti az egyes Fibonacci eredményeket.

using System;
using System.Threading;

public class Fibonacci
{
    private ManualResetEvent _doneEvent;

    public Fibonacci(int n, ManualResetEvent doneEvent)
    {
        N = n;
        _doneEvent = doneEvent;
    }

    public int N { get; }

    public int FibOfN { get; private set; }

    public void ThreadPoolCallback(Object threadContext)
    {
        int threadIndex = (int)threadContext;
        Console.WriteLine($"Thread {threadIndex} started...");
        FibOfN = Calculate(N);
        Console.WriteLine($"Thread {threadIndex} result calculated...");
        _doneEvent.Set();
    }

    public int Calculate(int n)
    {
        if (n <= 1)
        {
            return n;
        }
        return Calculate(n - 1) + Calculate(n - 2);
    }
}

public class ThreadPoolExample
{
    static void Main()
    {
        const int FibonacciCalculations = 5;

        var doneEvents = new ManualResetEvent[FibonacciCalculations];
        var fibArray = new Fibonacci[FibonacciCalculations];
        var rand = new Random();

        Console.WriteLine($"Launching {FibonacciCalculations} tasks...");
        for (int i = 0; i < FibonacciCalculations; i++)
        {
            doneEvents[i] = new ManualResetEvent(false);
            var f = new Fibonacci(rand.Next(20, 40), doneEvents[i]);
            fibArray[i] = f;
            ThreadPool.QueueUserWorkItem(f.ThreadPoolCallback, i);
        }

        WaitHandle.WaitAll(doneEvents);
        Console.WriteLine("All calculations are complete.");

        for (int i = 0; i < FibonacciCalculations; i++)
        {
            Fibonacci f = fibArray[i];
            Console.WriteLine($"Fibonacci({f.N}) = {f.FibOfN}");
        }
    }
}
// The output is similar to:
// Launching 5 tasks...
// Thread 3 started...
// Thread 4 started...
// Thread 2 started...
// Thread 1 started...
// Thread 0 started...
// Thread 2 result calculated...
// Thread 3 result calculated...
// Thread 4 result calculated...
// Thread 1 result calculated...
// Thread 0 result calculated...
// All calculations are complete.
// Fibonacci(35) = 9227465
// Fibonacci(27) = 196418
// Fibonacci(25) = 75025
// Fibonacci(25) = 75025
// Fibonacci(27) = 196418

Imports System.Threading

Public Class Fibonacci
    Private _doneEvent As ManualResetEvent

    Public Sub New(n As Integer, doneEvent As ManualResetEvent)
        Me.N = n
        _doneEvent = doneEvent
    End Sub

    Public ReadOnly Property N As Integer
    Public Property FibOfN As Integer

    Public Sub ThreadPoolCallback(threadContext As Object)
        Dim threadIndex As Integer = CType(threadContext, Integer)
        Console.WriteLine($"Thread {threadIndex} started...")
        FibOfN = Calculate(N)
        Console.WriteLine($"Thread {threadIndex} result calculated...")
        _doneEvent.Set()
    End Sub

    Public Function Calculate(n As Integer) As Integer
        If (n <= 1) Then
            Return n
        End If
        Return Calculate(n - 1) + Calculate(n - 2)
    End Function
End Class

Public Class ThreadPoolExample

    <MTAThread>
    Public Shared Sub Main()

        Const FibonacciCalculations As Integer = 5

        Dim doneEvents(FibonacciCalculations - 1) As ManualResetEvent
        Dim fibArray(FibonacciCalculations - 1) As Fibonacci
        Dim rand As Random = New Random()

        Console.WriteLine($"Launching {FibonacciCalculations} tasks...")

        For i As Integer = 0 To FibonacciCalculations - 1
            doneEvents(i) = New ManualResetEvent(False)
            Dim f As Fibonacci = New Fibonacci(rand.Next(20, 40), doneEvents(i))
            fibArray(i) = f
            ThreadPool.QueueUserWorkItem(AddressOf f.ThreadPoolCallback, i)
        Next

        WaitHandle.WaitAll(doneEvents)
        Console.WriteLine("All calculations are complete.")

        For i As Integer = 0 To FibonacciCalculations - 1
            Dim f As Fibonacci = fibArray(i)
            Console.WriteLine($"Fibonacci({f.N}) = {f.FibOfN}")
        Next
    End Sub
End Class
' Output is similar to
' Launching 5 tasks...
' Thread 1 started...
' Thread 2 started...
' Thread 3 started...
' Thread 4 started...
' Thread 0 started...
' Thread 4 result calculated...
' Thread 2 result calculated...
' Thread 3 result calculated...
' Thread 0 result calculated...
' Thread 1 result calculated...
' All calculations are complete.
' Fibonacci(37) = 24157817
' Fibonacci(38) = 39088169
' Fibonacci(29) = 514229
' Fibonacci(32) = 2178309
' Fibonacci(23) = 28657

Megjegyzések

Ha a visszahívási módszer összetett adatokat igényel, meghatározhat egy osztályt, amely tartalmazza az adatokat.

Note

Visual Basic felhasználók kihagyhatják a WaitCallback konstruktort, és egyszerűen használhatják a AddressOf operátort a visszahívási módszer QueueUserWorkItem. Visual Basic automatikusan meghívja a megfelelő delegált konstruktort.

Lásd még

• A felügyelt szálkészlet

QueueUserWorkItem<TState>(Action<TState>, TState, Boolean)

Forrás:

ThreadPoolWorkQueue.cs

Várólistára állítja a Action<T> meghatalmazott által a végrehajtáshoz megadott metódust, és megadja a metódus által használandó adatokat. A metódus akkor hajtja végre, ha egy szálkészlet szála elérhetővé válik.

public:
generic <typename TState>
 static bool QueueUserWorkItem(Action<TState> ^ callBack, TState state, bool preferLocal);

public static bool QueueUserWorkItem<TState>(Action<TState> callBack, TState state, bool preferLocal);

static member QueueUserWorkItem : Action<'State> * 'State * bool -> bool

Public Shared Function QueueUserWorkItem(Of TState) (callBack As Action(Of TState), state As TState, preferLocal As Boolean) As Boolean

Típusparaméterek

TState

Az elemek statetípusa.

Paraméterek

callBack

Action<TState>

A Action<T> végrehajtandó metódust jelképező.

state

TState

A metódus által használandó adatokat tartalmazó objektum.

preferLocal

Boolean

true a munkaelem várólistára helyezése az aktuális szálhoz közeli üzenetsorban; false a munkaelem üzenetsorba helyezése a szálkészlet megosztott üzenetsorához.

Válaszok

Boolean

true ha a metódus sikeresen várólistára van állítva; NotSupportedException akkor kerül sorba, ha a munkaelemet nem lehetett várólistára tenni.