CountdownEvent Sınıf

Tanım

Ad Alanı:

System.Threading

Bütünleştirilmiş Kodlar:

netstandard.dll, System.Threading.dll

Kaynak:

CountdownEvent.cs

Sayısı sıfıra ulaştığında işaretlenen bir eşitleme temel öğesini temsil eder.

public ref class CountdownEvent : IDisposable

public class CountdownEvent : IDisposable

type CountdownEvent = class
    interface IDisposable

Public Class CountdownEvent
Implements IDisposable

Devralma

Object

CountdownEvent

Uygulamalar

IDisposable

Örnekler

Aşağıdaki örnek, bir CountdownEvent'in nasıl kullanılacağını göstermektedir.

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

Oluşturucular

Name	Description
CountdownEvent(Int32)	Belirtilen sayıyla yeni bir sınıf örneği CountdownEvent başlatır.

Özellikler

Name	Description
CurrentCount	Olayı ayarlamak için gereken kalan sinyal sayısını alır.
InitialCount	Başlangıçta olayı ayarlamak için gereken sinyallerin sayısını alır.
IsSet	Nesnenin CountdownEvent geçerli sayısının sıfıra ulaşıp ulaşmadığını gösterir.
WaitHandle	Olayın ayarlanmasını beklemek için kullanılan bir WaitHandle alır.

Yöntemler

Name	Description
AddCount()	CountdownEvent'nin geçerli sayısını bir artırır.
AddCount(Int32)	CountdownEvent'nin geçerli sayısını belirtilen bir değere artırır.
Dispose()	Sınıfın geçerli örneği CountdownEvent tarafından kullanılan tüm kaynakları serbest bırakır.
Dispose(Boolean)	tarafından CountdownEventkullanılan yönetilmeyen kaynakları serbest bırakır ve isteğe bağlı olarak yönetilen kaynakları serbest bırakır.
Equals(Object)	Belirtilen nesnenin geçerli nesneye eşit olup olmadığını belirler. (Devralındığı yer: Object)
GetHashCode()	Varsayılan karma işlevi işlevi görür. (Devralındığı yer: Object)
GetType()	Geçerli örneğin Type alır. (Devralındığı yer: Object)
MemberwiseClone()	Geçerli Objectbasit bir kopyasını oluşturur. (Devralındığı yer: Object)
Reset()	değerini değerine CurrentCountsıfırlarInitialCount.
Reset(Int32)	Özelliği belirtilen bir değere sıfırlar InitialCount .
Signal()	değerini CountdownEventseçerek ile CurrentCountbir sinyal kaydeder.
Signal(Int32)	ile birden çok sinyal CountdownEventkaydeder ve değerini CurrentCount belirtilen miktara göre azaltma.
ToString()	Geçerli nesneyi temsil eden bir dize döndürür. (Devralındığı yer: Object)
TryAddCount()	Bir artırmayı CurrentCount dener.
TryAddCount(Int32)	Belirtilen bir değer artırmayı CurrentCount dener.
Wait()	ayarlanana kadar geçerli iş parçacığını CountdownEvent engeller.
Wait(CancellationToken)	bir gözlemlerken ayarlanana CountdownEvent kadar geçerli iş parçacığını CancellationTokenengeller.
Wait(Int32, CancellationToken)	zaman aşımını ölçmek için 32 bit imzalı bir tamsayı kullanarak ve gözlemlerken CountdownEventayarlanana kadar CancellationToken geçerli iş parçacığını engeller.
Wait(Int32)	zaman aşımını ölçmek için 32 bit imzalı bir tamsayı kullanarak ayarlanana kadar CountdownEvent geçerli iş parçacığını engeller.
Wait(TimeSpan, CancellationToken)	zaman aşımını ölçerken gözlemlerken CountdownEventkullanarak ayarlanana TimeSpan kadar CancellationToken geçerli iş parçacığını engeller.
Wait(TimeSpan)	zaman aşımını ölçmek için bir CountdownEvent kullanarak ayarlanana kadar TimeSpan geçerli iş parçacığını engeller.

İş Parçacığı Güvenliği

'nin CountdownEvent tüm genel ve korumalı üyeleri iş parçacığı açısından güvenlidir ve yalnızca ve üzerindeki Dispose() diğer tüm işlemler tamamlandığında kullanılması gereken ve CountdownEventyalnızca olaya başka iş parçacığı erişilmediğinde kullanılması gereken dışında Reset()birden çok iş parçacığından eşzamanlı olarak kullanılabilir.

Ayrıca bkz.

• CountdownEvent