CountdownEvent Třída

Definice

Obor názvů:

System.Threading

Sestavení:

System.Threading.dll

Source:

CountdownEvent.cs

Představuje primitiva synchronizace, která se signalizuje, když její počet dosáhne nuly.

public ref class CountdownEvent : IDisposable

public class CountdownEvent : IDisposable

type CountdownEvent = class
    interface IDisposable

Public Class CountdownEvent
Implements IDisposable

Dědičnost

Object

CountdownEvent

Implementuje

IDisposable

Příklady

Následující příklad ukazuje, jak použít CountdownEvent:

using System;
using System.Collections.Concurrent;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;

class Example
{
    static async Task Main()
    {
        // Initialize a queue and a CountdownEvent
        ConcurrentQueue<int> queue = new ConcurrentQueue<int>(Enumerable.Range(0, 10000));
        CountdownEvent cde = new CountdownEvent(10000); // initial count = 10000

        // This is the logic for all queue consumers
        Action consumer = () =>
        {
            int local;
            // decrement CDE count once for each element consumed from queue
            while (queue.TryDequeue(out local)) cde.Signal();
        };

        // Now empty the queue with a couple of asynchronous tasks
        Task t1 = Task.Factory.StartNew(consumer);
        Task t2 = Task.Factory.StartNew(consumer);

        // And wait for queue to empty by waiting on cde
        cde.Wait(); // will return when cde count reaches 0

        Console.WriteLine("Done emptying queue.  InitialCount={0}, CurrentCount={1}, IsSet={2}",
            cde.InitialCount, cde.CurrentCount, cde.IsSet);

        // Proper form is to wait for the tasks to complete, even if you know that their work
        // is done already.
        await Task.WhenAll(t1, t2);

        // Resetting will cause the CountdownEvent to un-set, and resets InitialCount/CurrentCount
        // to the specified value
        cde.Reset(10);

        // AddCount will affect the CurrentCount, but not the InitialCount
        cde.AddCount(2);

        Console.WriteLine("After Reset(10), AddCount(2): InitialCount={0}, CurrentCount={1}, IsSet={2}",
            cde.InitialCount, cde.CurrentCount, cde.IsSet);

        // Now try waiting with cancellation
        CancellationTokenSource cts = new CancellationTokenSource();
        cts.Cancel(); // cancels the CancellationTokenSource
        try
        {
            cde.Wait(cts.Token);
        }
        catch (OperationCanceledException)
        {
            Console.WriteLine("cde.Wait(preCanceledToken) threw OCE, as expected");
        }
        finally
        {
           cts.Dispose();
        }
        // It's good to release a CountdownEvent when you're done with it.
        cde.Dispose();
    }
}
// The example displays the following output:
//    Done emptying queue.  InitialCount=10000, CurrentCount=0, IsSet=True
//    After Reset(10), AddCount(2): InitialCount=10, CurrentCount=12, IsSet=False
//    cde.Wait(preCanceledToken) threw OCE, as expected

Imports System.Collections.Concurrent
Imports System.Linq
Imports System.Threading
Imports System.Threading.Tasks

Module Example
    Sub Main()
        ' Initialize a queue and a CountdownEvent
        Dim queue As New ConcurrentQueue(Of Integer)(Enumerable.Range(0, 10000))
        Dim cde As New CountdownEvent(10000)
        ' initial count = 10000
        ' This is the logic for all queue consumers
        Dim consumer As Action =
            Sub()
                Dim local As Integer
                ' decrement CDE count once for each element consumed from queue
                While queue.TryDequeue(local)
                    cde.Signal()
                End While
            End Sub

        ' Now empty the queue with a couple of asynchronous tasks
        Dim t1 As Task = Task.Factory.StartNew(consumer)
        Dim t2 As Task = Task.Factory.StartNew(consumer)

        ' And wait for queue to empty by waiting on cde
        cde.Wait()
        ' will return when cde count reaches 0
        Console.WriteLine("Done emptying queue. InitialCount={0}, CurrentCount={1}, IsSet={2}", cde.InitialCount, cde.CurrentCount, cde.IsSet)

        ' Proper form is to wait for the tasks to complete, even if you know that their work
        ' is done already.
        Task.WaitAll(t1, t2)

        ' Resetting will cause the CountdownEvent to un-set, and resets InitialCount/CurrentCount
        ' to the specified value
        cde.Reset(10)

        ' AddCount will affect the CurrentCount, but not the InitialCount
        cde.AddCount(2)

        Console.WriteLine("After Reset(10), AddCount(2): InitialCount={0}, CurrentCount={1}, IsSet={2}", cde.InitialCount, cde.CurrentCount, cde.IsSet)

        ' Now try waiting with cancellation
        Dim cts As New CancellationTokenSource()
        cts.Cancel()
        ' cancels the CancellationTokenSource
        Try
            cde.Wait(cts.Token)
        Catch generatedExceptionName As OperationCanceledException
            Console.WriteLine("cde.Wait(preCanceledToken) threw OCE, as expected")
        Finally
           cts.Dispose()
        End Try

        ' It's good to release a CountdownEvent when you're done with it.
        cde.Dispose()
    End Sub
End Module
' The example displays the following output:
'    Done emptying queue.  InitialCount=10000, CurrentCount=0, IsSet=True
'    After Reset(10), AddCount(2): InitialCount=10, CurrentCount=12, IsSet=False
'    cde.Wait(preCanceledToken) threw OCE, as expected

Konstruktory

CountdownEvent(Int32)

Inicializuje novou instanci CountdownEvent třídy se zadaným počtem.

Vlastnosti

CurrentCount	Získá počet zbývajících signálů potřebných k nastavení události.
InitialCount	Získá počet signálů původně potřebných k nastavení události.
IsSet	Určuje, jestli aktuální počet objektu CountdownEvent dosáhl nuly.
WaitHandle	Získá, WaitHandle který se používá k čekání na nastavení události.

Metody

AddCount()	Zvýší CountdownEventaktuální počet o jednu.
AddCount(Int32)	Zvýší CountdownEventaktuální počet o zadanou hodnotu.
Dispose()	Uvolní všechny prostředky používané aktuální instancí CountdownEvent třídy.
Dispose(Boolean)	Uvolní nespravované prostředky používané nástrojem CountdownEventa volitelně uvolní spravované prostředky.
Equals(Object)	Určí, zda se zadaný objekt rovná aktuálnímu objektu. (Zděděno od Object)
GetHashCode()	Slouží jako výchozí hashovací funkce. (Zděděno od Object)
GetType()	Získá aktuální Type instanci. (Zděděno od Object)
MemberwiseClone()	Vytvoří mělkou kopii aktuálního Objectsouboru . (Zděděno od Object)
Reset()	Obnoví hodnotu CurrentCount na hodnotu InitialCount.
Reset(Int32)	InitialCount Obnoví vlastnost na zadanou hodnotu.
Signal()	Zaregistruje signál s CountdownEventhodnotou , která snižuje hodnotu .CurrentCount
Signal(Int32)	Registruje více signálů s CountdownEventhodnotou , která snižuje hodnotu o CurrentCount zadanou hodnotu.
ToString()	Vrátí řetězec, který představuje aktuální objekt. (Zděděno od Object)
TryAddCount()	Pokusy o zvýšení CurrentCount o jednu.
TryAddCount(Int32)	Pokusí se zvýšit CurrentCount o zadanou hodnotu.
Wait()	Zablokuje aktuální vlákno, dokud se nenastaví CountdownEvent .
Wait(CancellationToken)	Zablokuje aktuální vlákno, dokud CountdownEvent se nenastaví, zatímco se pozoruje CancellationToken.
Wait(Int32)	Zablokuje aktuální vlákno, dokud CountdownEvent se nenastaví. K měření časového limitu se použije celé číslo se 32bitovým signedm..
Wait(Int32, CancellationToken)	Zablokuje aktuální vlákno, dokud CountdownEvent se nenastaví, pomocí 32bitového celého čísla se signým číslem změří časový limit při pozorování CancellationToken.
Wait(TimeSpan)	Zablokuje aktuální vlákno, dokud CountdownEvent se nenastaví, pomocí parametru TimeSpan pro měření časového limitu.
Wait(TimeSpan, CancellationToken)	Zablokuje aktuální vlákno, dokud CountdownEvent se nenastaví, pomocí parametru TimeSpan k měření časového limitu CancellationTokenpři sledování .

Bezpečný přístup z více vláken

Všechny veřejné a chráněné členy CountdownEvent jsou bezpečné pro přístup z více vláken a lze je používat současně z více vláken s výjimkou Dispose(), který se musí použít pouze v případě, že se dokončily všechny ostatní operace na CountdownEvent a , které by se měly použít pouze v případě, Reset()že k události nepřistupují žádná jiná vlákna.

Viz také

• CountdownEvent