CountdownEvent Sınıf

Tanım

Ad Alanı:

System.Threading

Bütünleştirilmiş Kod:

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 örnekte bir 'nin nasıl kullanılacağı gösterilmektedir 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

Oluşturucular

CountdownEvent(Int32)

Belirtilen sayıda yeni bir sınıf örneği CountdownEvent başlatır.

Özellikler

CurrentCount	Olayı ayarlamak için gereken kalan sinyal sayısını alır.
InitialCount	Başlangıçta olayı ayarlamak için gereken sinyal 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

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()	CountdownEvent sınıfının geçerli örneği 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()	Type Geçerli örneğini alır. (Devralındığı yer: Object)
MemberwiseClone()	Geçerli Objectöğesinin sığ bir kopyasını oluşturur. (Devralındığı yer: Object)
Reset()	değerini değerine InitialCountsıfırlarCurrentCount.
Reset(Int32)	Özelliği belirtilen bir değere sıfırlar InitialCount .
Signal()	değerini CurrentCountazaltması CountdownEventiçin ile bir sinyal kaydeder.
Signal(Int32)	ile birden çok sinyal CountdownEventkaydeder ve değerini CurrentCount belirtilen miktara göre azaltma.
ToString()	Geçerli nesneyi temsil eden dizeyi döndürür. (Devralındığı yer: Object)
TryAddCount()	Bir artırma CurrentCount denemesi.
TryAddCount(Int32)	Belirtilen bir değer artırmayı CurrentCount dener.
Wait()	ayarlanana kadar geçerli iş parçacığını CountdownEvent engeller.
Wait(CancellationToken)	ayarlanana kadar geçerli iş parçacığını CountdownEvent engeller ve bunu CancellationTokengözlemlerken .
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(Int32, CancellationToken)	zaman aşımını ölçerken gözlemlerken CancellationToken32 bit imzalı bir tamsayı kullanarak ayarlanana kadar CountdownEvent geçerli iş parçacığını engeller.
Wait(TimeSpan)	zaman aşımını ölçmek için bir TimeSpan kullanarak ayarlanana kadar CountdownEvent geçerli iş parçacığını engeller.
Wait(TimeSpan, CancellationToken)	zaman aşımını ölçerken gözlemlerken CancellationTokenbir TimeSpan kullanarak ayarlanana kadar CountdownEvent geçerli iş parçacığını engeller.

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

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

Ayrıca bkz.

• CountdownEvent