AutoResetEvent(Boolean) Konstruktor

Definicja

Przestrzeń nazw:

System.Threading

Zestaw:

System.Threading.dll

Źródło:

AutoResetEvent.cs

Inicjuje AutoResetEvent nowe wystąpienie klasy z wartością logiczną wskazującą, czy ustawić stan początkowy na sygnalizowany.

public:
 AutoResetEvent(bool initialState);

public AutoResetEvent (bool initialState);

new System.Threading.AutoResetEvent : bool -> System.Threading.AutoResetEvent

Public Sub New (initialState As Boolean)

Parametry

initialState

Boolean

true aby ustawić stan początkowy na sygnalizowany; false , aby ustawić stan początkowy na niesygnalizowany.

Przykłady

W poniższym przykładzie użyto elementu , AutoResetEvent aby zsynchronizować działania dwóch wątków. Pierwszy wątek, który jest wątkiem aplikacji, wykonuje polecenie Main. Zapisuje wartości w chronionym zasobie, czyli static pole (Shared w Visual Basic) o nazwie number. Drugi wątek wykonuje metodę statyczną ThreadProc , która odczytuje wartości zapisane przez Main.

Metoda ThreadProc czeka na AutoResetEvent. Gdy Main metoda wywołuje metodę Set w metodzie AutoResetEvent, ThreadProc metoda odczytuje jedną wartość. Metoda AutoResetEvent natychmiast resetuje, więc ThreadProc metoda czeka ponownie.

Logika programu gwarantuje, że ThreadProc metoda nigdy nie odczytuje tej samej wartości dwa razy. Nie gwarantuje ona, że ThreadProc metoda odczytuje każdą wartość zapisaną przez Mainmetodę . Ta gwarancja wymagałaby drugiej AutoResetEvent blokady.

Po każdej operacji Main zapisu daje wartość przez wywołanie Thread.Sleep metody , aby dać drugiemu wątkowi szansę na wykonanie. W przeciwnym razie na komputerze Main z jednym procesorem będzie zapisywać wiele wartości między dowolnymi dwoma operacjami odczytu.

using namespace System;
using namespace System::Threading;
ref class MyMainClass
{
public:
   static void MyReadThreadProc()
   {
      while ( true )
      {
         
         //The value will not be read until the writer has written
         // at least once since the last read.
         myResetEvent->WaitOne();
         Console::WriteLine( " {0} reading value: {1}", Thread::CurrentThread->Name, number );
      }
   }


   //Initially not signaled.
   static AutoResetEvent^ myResetEvent = gcnew AutoResetEvent( false );
   static int number;
   literal int numIterations = 100;
};

int main()
{
   
   //Create and start the reader thread.
   Thread^ myReaderThread = gcnew Thread( gcnew ThreadStart( MyMainClass::MyReadThreadProc ) );
   myReaderThread->Name = "ReaderThread";
   myReaderThread->Start();
   for ( int i = 1; i <= MyMainClass::numIterations; i++ )
   {
      Console::WriteLine( "Writer thread writing value: {0}", i );
      MyMainClass::number = i;
      
      //Signal that a value has been written.
      MyMainClass::myResetEvent->Set();
      
      //Give the Reader thread an opportunity to act.
      Thread::Sleep( 1 );

   }
   
   //Terminate the reader thread.
   myReaderThread->Abort();
}

using System;
using System.Threading;

namespace AutoResetEvent_Examples
{
    class MyMainClass
    {
        //Initially not signaled.
      const int numIterations = 100;
      static AutoResetEvent myResetEvent = new AutoResetEvent(false);
      static int number;
      
      static void Main()
        {
         //Create and start the reader thread.
         Thread myReaderThread = new Thread(new ThreadStart(MyReadThreadProc));
         myReaderThread.Name = "ReaderThread";
         myReaderThread.Start();

         for(int i = 1; i <= numIterations; i++)
         {
            Console.WriteLine("Writer thread writing value: {0}", i);
            number = i;
            
            //Signal that a value has been written.
            myResetEvent.Set();
            
            //Give the Reader thread an opportunity to act.
            Thread.Sleep(1);
         }

         //Terminate the reader thread.
         myReaderThread.Abort();
      }

      static void MyReadThreadProc()
      {
         while(true)
         {
            //The value will not be read until the writer has written
            // at least once since the last read.
            myResetEvent.WaitOne();
            Console.WriteLine("{0} reading value: {1}", Thread.CurrentThread.Name, number);
         }
      }
    }
}

Imports System.Threading

Namespace AutoResetEvent_Examples
    Class MyMainClass
        'Initially not signaled.
        Private Const numIterations As Integer = 100
        Private Shared myResetEvent As New AutoResetEvent(False)
        Private Shared number As Integer

        <MTAThread> _
        Shared Sub Main()
            'Create and start the reader thread.
            Dim myReaderThread As New Thread(AddressOf MyReadThreadProc)
            myReaderThread.Name = "ReaderThread"
            myReaderThread.Start()

            Dim i As Integer
            For i = 1 To numIterations
                Console.WriteLine("Writer thread writing value: {0}", i)
                number = i

                'Signal that a value has been written.
                myResetEvent.Set()

                'Give the Reader thread an opportunity to act.
                Thread.Sleep(1)
            Next i

            'Terminate the reader thread.
            myReaderThread.Abort()
        End Sub

        Shared Sub MyReadThreadProc()
            While True
                'The value will not be read until the writer has written
                ' at least once since the last read.
                myResetEvent.WaitOne()
                Console.WriteLine("{0} reading value: {1}", Thread.CurrentThread.Name, number)
            End While
        End Sub
    End Class
End Namespace 'AutoResetEvent_Examples

Zobacz też

• WaitHandle
• Zarządzane wątkowanie
• Przegląd elementów podstawowych synchronizacji