Semaphore Konstruktoren

Quelle:

Semaphore.cs

Quelle:

Semaphore.cs

Quelle:

Semaphore.cs

Quelle:

Semaphore.cs

Quelle:

Semaphore.cs

public:
 Semaphore(int initialCount, int maximumCount);

public Semaphore(int initialCount, int maximumCount);

new System.Threading.Semaphore : int * int -> System.Threading.Semaphore

Public Sub New (initialCount As Integer, maximumCount As Integer)

Parameter

Ausnahmen

Beispiele

Im folgenden Beispiel wird ein Semaphor mit einer maximalen Anzahl von drei und einer anfänglichen Anzahl von Null erstellt. Das Beispiel startet fünf Threads, die auf das Semaphor warten. Der Hauptthread verwendet die Release(Int32) Methodenüberladung, um die Semaphoranzahl auf sein Maximum zu erhöhen, sodass drei Threads in das Semaphor gelangen können. Jeder Thread verwendet die Thread.Sleep Methode, um eine Sekunde zu warten, um Arbeit zu simulieren, und ruft dann die Release() Methodenüberladung auf, um das Semaphor freizugeben. Jedes Mal, wenn der Semaphor losgelassen wird, wird die vorherige Semaphoranzahl angezeigt. Konsolennachrichten verfolgen die Verwendung von Semaphoren. Das simulierte Arbeitsintervall wird für jeden Thread leicht erhöht, um die Ausgabe leichter lesbar zu machen.

using System;
using System.Threading;

public class Example
{
    // A semaphore that simulates a limited resource pool.
    //
    private static Semaphore _pool;

    // A padding interval to make the output more orderly.
    private static int _padding;

    public static void Main()
    {
        // Create a semaphore that can satisfy up to three
        // concurrent requests. Use an initial count of zero,
        // so that the entire semaphore count is initially
        // owned by the main program thread.
        //
        _pool = new Semaphore(initialCount: 0, maximumCount: 3);

        // Create and start five numbered threads. 
        //
        for(int i = 1; i <= 5; i++)
        {
            Thread t = new Thread(new ParameterizedThreadStart(Worker));

            // Start the thread, passing the number.
            //
            t.Start(i);
        }

        // Wait for half a second, to allow all the
        // threads to start and to block on the semaphore.
        //
        Thread.Sleep(500);

        // The main thread starts out holding the entire
        // semaphore count. Calling Release(3) brings the 
        // semaphore count back to its maximum value, and
        // allows the waiting threads to enter the semaphore,
        // up to three at a time.
        //
        Console.WriteLine("Main thread calls Release(3).");
        _pool.Release(releaseCount: 3);

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

    private static void Worker(object num)
    {
        // Each worker thread begins by requesting the
        // semaphore.
        Console.WriteLine("Thread {0} begins " +
            "and waits for the semaphore.", num);
        _pool.WaitOne();

        // A padding interval to make the output more orderly.
        int padding = Interlocked.Add(ref _padding, 100);

        Console.WriteLine("Thread {0} enters the semaphore.", num);
        
        // The thread's "work" consists of sleeping for 
        // about a second. Each thread "works" a little 
        // longer, just to make the output more orderly.
        //
        Thread.Sleep(1000 + padding);

        Console.WriteLine("Thread {0} releases the semaphore.", num);
        Console.WriteLine("Thread {0} previous semaphore count: {1}",
            num, _pool.Release());
    }
}

Imports System.Threading

Public Class Example

    ' A semaphore that simulates a limited resource pool.
    '
    Private Shared _pool As Semaphore

    ' A padding interval to make the output more orderly.
    Private Shared _padding As Integer

    <MTAThread> _
    Public Shared Sub Main()
        ' Create a semaphore that can satisfy up to three
        ' concurrent requests. Use an initial count of zero,
        ' so that the entire semaphore count is initially
        ' owned by the main program thread.
        '
        _pool = New Semaphore(0, 3)

        ' Create and start five numbered threads. 
        '
        For i As Integer = 1 To 5
            Dim t As New Thread(New ParameterizedThreadStart(AddressOf Worker))
            'Dim t As New Thread(AddressOf Worker)

            ' Start the thread, passing the number.
            '
            t.Start(i)
        Next i

        ' Wait for half a second, to allow all the
        ' threads to start and to block on the semaphore.
        '
        Thread.Sleep(500)

        ' The main thread starts out holding the entire
        ' semaphore count. Calling Release(3) brings the 
        ' semaphore count back to its maximum value, and
        ' allows the waiting threads to enter the semaphore,
        ' up to three at a time.
        '
        Console.WriteLine("Main thread calls Release(3).")
        _pool.Release(3)

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

    Private Shared Sub Worker(ByVal num As Object)
        ' Each worker thread begins by requesting the
        ' semaphore.
        Console.WriteLine("Thread {0} begins " _
            & "and waits for the semaphore.", num)
        _pool.WaitOne()

        ' A padding interval to make the output more orderly.
        Dim padding As Integer = Interlocked.Add(_padding, 100)

        Console.WriteLine("Thread {0} enters the semaphore.", num)
        
        ' The thread's "work" consists of sleeping for 
        ' about a second. Each thread "works" a little 
        ' longer, just to make the output more orderly.
        '
        Thread.Sleep(1000 + padding)

        Console.WriteLine("Thread {0} releases the semaphore.", num)
        Console.WriteLine("Thread {0} previous semaphore count: {1}", _
            num, _
            _pool.Release())
    End Sub
End Class

Hinweise

Dieser Konstruktor initialisiert ein unbenannte Semaphor. Alle Threads, die eine Instanz eines solchen Semaphors verwenden, müssen Verweise auf die Instanz haben.

Ist initialCount der Effekt kleiner als maximumCount, ist der Effekt identisch mit dem Aufruf des aktuellen Threads WaitOne (maximumCount minus initialCount) Zeiten. Wenn Sie keine Einträge für den Thread reservieren möchten, der das Semaphor erstellt, verwenden Sie dieselbe Zahl für maximumCount und initialCount.

Weitere Informationen

• Verwaltetes Thread-Management
• Semaphor

Quelle:

Semaphore.cs

Quelle:

Semaphore.cs

Quelle:

Semaphore.cs

Quelle:

Semaphore.cs

Quelle:

Semaphore.cs

public:
 Semaphore(int initialCount, int maximumCount, System::String ^ name);

public Semaphore(int initialCount, int maximumCount, string name);

public Semaphore(int initialCount, int maximumCount, string? name);

new System.Threading.Semaphore : int * int * string -> System.Threading.Semaphore

Public Sub New (initialCount As Integer, maximumCount As Integer, name As String)

Parameter

Ausnahmen

Beispiele

Im folgenden Codebeispiel wird das prozessübergreifende Verhalten eines benannten Semaphors veranschaulicht. Im Beispiel wird ein benanntes Semaphor mit einer maximalen Anzahl von fünf und einer Anfangsanzahl von fünf erstellt. Das Programm führt drei Aufrufe an die WaitOne Methode durch. Wenn Sie also das kompilierte Beispiel aus zwei Befehlsfenstern ausführen, wird die zweite Kopie für den dritten Aufruf WaitOneblockiert. Geben Sie einen oder mehrere Einträge in der ersten Kopie des Programms frei, um die Blockierung der zweiten zu entsperren.

using System;
using System.Threading;

public class Example
{
    public static void Main()
    {
        // Create a Semaphore object that represents the named 
        // system semaphore "SemaphoreExample3". The semaphore has a
        // maximum count of five. The initial count is also five. 
        // There is no point in using a smaller initial count,
        // because the initial count is not used if this program
        // doesn't create the named system semaphore, and with 
        // this method overload there is no way to tell. Thus, this
        // program assumes that it is competing with other
        // programs for the semaphore.
        //
        Semaphore sem = new Semaphore(5, 5, "SemaphoreExample3");

        // Attempt to enter the semaphore three times. If another 
        // copy of this program is already running, only the first
        // two requests can be satisfied. The third blocks. Note 
        // that in a real application, timeouts should be used
        // on the WaitOne calls, to avoid deadlocks.
        //
        sem.WaitOne();
        Console.WriteLine("Entered the semaphore once.");
        sem.WaitOne();
        Console.WriteLine("Entered the semaphore twice.");
        sem.WaitOne();
        Console.WriteLine("Entered the semaphore three times.");

        // The thread executing this program has entered the 
        // semaphore three times. If a second copy of the program
        // is run, it will block until this program releases the 
        // semaphore at least once.
        //
        Console.WriteLine("Enter the number of times to call Release.");
        int n;
        if (int.TryParse(Console.ReadLine(), out n))
        {
            sem.Release(n);
        }

        int remaining = 3 - n;
        if (remaining > 0)
        {
            Console.WriteLine("Press Enter to release the remaining " +
                "count ({0}) and exit the program.", remaining);
            Console.ReadLine();
            sem.Release(remaining);
        }
    }
}

Imports System.Threading

Public Class Example

    <MTAThread> _
    Public Shared Sub Main()
        ' Create a Semaphore object that represents the named 
        ' system semaphore "SemaphoreExample3". The semaphore has a
        ' maximum count of five. The initial count is also five. 
        ' There is no point in using a smaller initial count,
        ' because the initial count is not used if this program
        ' doesn't create the named system semaphore, and with 
        ' this method overload there is no way to tell. Thus, this
        ' program assumes that it is competing with other
        ' programs for the semaphore.
        '
        Dim sem As New Semaphore(5, 5, "SemaphoreExample3")

        ' Attempt to enter the semaphore three times. If another 
        ' copy of this program is already running, only the first
        ' two requests can be satisfied. The third blocks. Note 
        ' that in a real application, timeouts should be used
        ' on the WaitOne calls, to avoid deadlocks.
        '
        sem.WaitOne()
        Console.WriteLine("Entered the semaphore once.")
        sem.WaitOne()
        Console.WriteLine("Entered the semaphore twice.")
        sem.WaitOne()
        Console.WriteLine("Entered the semaphore three times.")

        ' The thread executing this program has entered the 
        ' semaphore three times. If a second copy of the program
        ' is run, it will block until this program releases the 
        ' semaphore at least once.
        '
        Console.WriteLine("Enter the number of times to call Release.")
        Dim n As Integer
        If Integer.TryParse(Console.ReadLine(), n) Then
            sem.Release(n)
        End If

        Dim remaining As Integer = 3 - n
        If (remaining) > 0 Then
            Console.WriteLine("Press Enter to release the remaining " _
                & "count ({0}) and exit the program.", remaining)
            Console.ReadLine()
            sem.Release(remaining)
        End If

    End Sub 
End Class

Hinweise

Dieser Konstruktor initialisiert ein Semaphore Objekt, das einen benannten Systemsemaphor darstellt. Sie können mehrere Semaphore Objekte erstellen, die denselben benannten Systemsemaphor darstellen.

Möglicherweise name wird dem Namespace ein Präfix vorangestellt Global\ oder Local\ angegeben. Wenn der Global Namespace angegeben ist, kann das Synchronisierungsobjekt für alle Prozesse im System freigegeben werden. Wenn der Local Namespace angegeben ist, was auch der Standardwert ist, wenn kein Namespace angegeben wird, kann das Synchronisierungsobjekt für Prozesse in derselben Sitzung freigegeben werden. Bei Windows ist eine Sitzung eine Anmeldesitzung, und Dienste werden in der Regel in einer anderen nicht interaktiven Sitzung ausgeführt. Auf Unix-ähnlichen Betriebssystemen verfügt jede Shell über eine eigene Sitzung. Sitzungslokale Synchronisierungsobjekte können für die Synchronisierung zwischen Prozessen mit einer Beziehung zwischen übergeordnetem/untergeordnetem Element geeignet sein, in der sie alle in derselben Sitzung ausgeführt werden. Weitere Informationen zu Synchronisierungsobjektnamen in Windows finden Sie unter Object Names.

Wenn ein name Synchronisierungsobjekt des angeforderten Typs bereits im Namespace vorhanden ist, wird das vorhandene Synchronisierungsobjekt verwendet. Wenn bereits ein Synchronisierungsobjekt eines anderen Typs im Namespace vorhanden ist, wird ein WaitHandleCannotBeOpenedException Fehler ausgelöst. Andernfalls wird ein neues Synchronisierungsobjekt erstellt.

Wenn der benannte System-Semaphor nicht vorhanden ist, wird es mit der anfänglichen Anzahl und der maximalen Anzahl erstellt, die durch initialCount und .maximumCount Wenn der benannte Systemsemaphor bereits vorhanden ist und initialCount nicht verwendet wird, maximumCount obwohl ungültige Werte weiterhin Ausnahmen verursachen. Wenn Sie ermitteln müssen, ob ein benanntes System-Semaphor erstellt wurde, verwenden Sie stattdessen die Semaphore(Int32, Int32, String, Boolean) Konstruktorüberladung.

Wenn Sie eine leere Zeichenfolge angeben oder eine leere Zeichenfolge angeben nullname, wird ein lokales Semaphor erstellt, als hätten Sie die Semaphore(Int32, Int32) Konstruktorüberladung aufgerufen.

Da benannte Semaphore im gesamten Betriebssystem sichtbar sind, können sie verwendet werden, um die Ressourcennutzung über Prozessgrenzen hinweg zu koordinieren.

Wenn Sie herausfinden möchten, ob ein benanntes Systemsemaphor vorhanden ist, verwenden Sie die OpenExisting Methode. Die OpenExisting Methode versucht, ein vorhandenes benanntes Semaphor zu öffnen, und löst eine Ausnahme aus, wenn das System-Semaphor nicht vorhanden ist.

Weitere Informationen

• Verwaltetes Thread-Management
• Semaphor

Quelle:

Semaphore.cs

Quelle:

Semaphore.cs

Quelle:

Semaphore.cs

Quelle:

Semaphore.cs

Quelle:

Semaphore.cs

public:
 Semaphore(int initialCount, int maximumCount, System::String ^ name, [Runtime::InteropServices::Out] bool % createdNew);

public Semaphore(int initialCount, int maximumCount, string name, out bool createdNew);

public Semaphore(int initialCount, int maximumCount, string? name, out bool createdNew);

new System.Threading.Semaphore : int * int * string * bool -> System.Threading.Semaphore

Public Sub New (initialCount As Integer, maximumCount As Integer, name As String, ByRef createdNew As Boolean)

Parameter

Ausnahmen

Beispiele

Im folgenden Codebeispiel wird das prozessübergreifende Verhalten eines benannten Semaphors veranschaulicht. Das Beispiel erstellt einen benannten Semaphor mit einer maximalen Anzahl von fünf und einer ersten Anzahl von zwei. Das heißt, es reserviert drei Einträge für den Thread, der den Konstruktor aufruft. Wenn createNew ja false, führt das Programm drei Aufrufe an die WaitOne Methode durch. Wenn Sie also das kompilierte Beispiel aus zwei Befehlsfenstern ausführen, wird die zweite Kopie für den dritten Aufruf WaitOneblockiert. Geben Sie einen oder mehrere Einträge in der ersten Kopie des Programms frei, um die Blockierung der zweiten zu entsperren.

using System;
using System.Threading;

public class Example
{
    public static void Main()
    {
        // The value of this variable is set by the semaphore
        // constructor. It is true if the named system semaphore was
        // created, and false if the named semaphore already existed.
        //
        bool semaphoreWasCreated;

        // Create a Semaphore object that represents the named 
        // system semaphore "SemaphoreExample". The semaphore has a
        // maximum count of five, and an initial count of two. The
        // Boolean value that indicates creation of the underlying 
        // system object is placed in semaphoreWasCreated.
        //
        Semaphore sem = new Semaphore(2, 5, "SemaphoreExample", 
            out semaphoreWasCreated);

        if (semaphoreWasCreated)
        {
            // If the named system semaphore was created, its count is
            // set to the initial count requested in the constructor.
            // In effect, the current thread has entered the semaphore
            // three times.
            // 
            Console.WriteLine("Entered the semaphore three times.");
        }
        else
        {      
            // If the named system semaphore was not created,  
            // attempt to enter it three times. If another copy of
            // this program is already running, only the first two
            // requests can be satisfied. The third blocks.
            //
            sem.WaitOne();
            Console.WriteLine("Entered the semaphore once.");
            sem.WaitOne();
            Console.WriteLine("Entered the semaphore twice.");
            sem.WaitOne();
            Console.WriteLine("Entered the semaphore three times.");
        }

        // The thread executing this program has entered the 
        // semaphore three times. If a second copy of the program
        // is run, it will block until this program releases the 
        // semaphore at least once.
        //
        Console.WriteLine("Enter the number of times to call Release.");
        int n;
        if (int.TryParse(Console.ReadLine(), out n))
        {
            sem.Release(n);
        }

        int remaining = 3 - n;
        if (remaining > 0)
        {
            Console.WriteLine("Press Enter to release the remaining " +
                "count ({0}) and exit the program.", remaining);
            Console.ReadLine();
            sem.Release(remaining);
        }
    } 
}

Imports System.Threading

Public Class Example

    <MTAThread> _
    Public Shared Sub Main()
        ' The value of this variable is set by the semaphore
        ' constructor. It is True if the named system semaphore was
        ' created, and False if the named semaphore already existed.
        '
        Dim semaphoreWasCreated As Boolean

        ' Create a Semaphore object that represents the named 
        ' system semaphore "SemaphoreExample". The semaphore has a
        ' maximum count of five, and an initial count of two. The
        ' Boolean value that indicates creation of the underlying 
        ' system object is placed in semaphoreWasCreated.
        '
        Dim sem As New Semaphore(2, 5, "SemaphoreExample", _
            semaphoreWasCreated)

        If semaphoreWasCreated Then
            ' If the named system semaphore was created, its count is
            ' set to the initial count requested in the constructor.
            ' In effect, the current thread has entered the semaphore
            ' three times.
            ' 
            Console.WriteLine("Entered the semaphore three times.")
        Else
            ' If the named system semaphore was not created,  
            ' attempt to enter it three times. If another copy of
            ' this program is already running, only the first two
            ' requests can be satisfied. The third blocks.
            '
            sem.WaitOne()
            Console.WriteLine("Entered the semaphore once.")
            sem.WaitOne()
            Console.WriteLine("Entered the semaphore twice.")
            sem.WaitOne()
            Console.WriteLine("Entered the semaphore three times.")
        End If

        ' The thread executing this program has entered the 
        ' semaphore three times. If a second copy of the program
        ' is run, it will block until this program releases the 
        ' semaphore at least once.
        '
        Console.WriteLine("Enter the number of times to call Release.")
        Dim n As Integer
        If Integer.TryParse(Console.ReadLine(), n) Then
            sem.Release(n)
        End If

        Dim remaining As Integer = 3 - n
        If (remaining) > 0 Then
            Console.WriteLine("Press Enter to release the remaining " _
                & "count ({0}) and exit the program.", remaining)
            Console.ReadLine()
            sem.Release(remaining)
        End If

    End Sub 
End Class

Hinweise

Möglicherweise name wird dem Namespace ein Präfix vorangestellt Global\ oder Local\ angegeben. Wenn der Global Namespace angegeben ist, kann das Synchronisierungsobjekt für alle Prozesse im System freigegeben werden. Wenn der Local Namespace angegeben ist, was auch der Standardwert ist, wenn kein Namespace angegeben wird, kann das Synchronisierungsobjekt für Prozesse in derselben Sitzung freigegeben werden. Bei Windows ist eine Sitzung eine Anmeldesitzung, und Dienste werden in der Regel in einer anderen nicht interaktiven Sitzung ausgeführt. Auf Unix-ähnlichen Betriebssystemen verfügt jede Shell über eine eigene Sitzung. Sitzungslokale Synchronisierungsobjekte können für die Synchronisierung zwischen Prozessen mit einer Beziehung zwischen übergeordnetem/untergeordnetem Element geeignet sein, in der sie alle in derselben Sitzung ausgeführt werden. Weitere Informationen zu Synchronisierungsobjektnamen in Windows finden Sie unter Object Names.

Wenn ein name Synchronisierungsobjekt des angeforderten Typs bereits im Namespace vorhanden ist, wird das vorhandene Synchronisierungsobjekt verwendet. Wenn bereits ein Synchronisierungsobjekt eines anderen Typs im Namespace vorhanden ist, wird ein WaitHandleCannotBeOpenedException Fehler ausgelöst. Andernfalls wird ein neues Synchronisierungsobjekt erstellt.

Dieser Konstruktor initialisiert ein Semaphore Objekt, das einen benannten Systemsemaphor darstellt. Sie können mehrere Semaphore Objekte erstellen, die denselben benannten Systemsemaphor darstellen.

Wenn der benannte System-Semaphor nicht vorhanden ist, wird es mit der anfänglichen Anzahl und der maximalen Anzahl erstellt, die durch initialCount und .maximumCount Wenn der benannte Systemsemaphor bereits vorhanden ist und initialCount nicht verwendet wird, maximumCount obwohl ungültige Werte weiterhin Ausnahmen verursachen. Verwenden Sie createdNew diese Eigenschaft, um zu bestimmen, ob das System-Semaphor erstellt wurde.

Wenn initialCount sie kleiner als maximumCountist und createdNew ist, ist trueder Effekt identisch mit dem Aufruf des aktuellen Threads WaitOne (maximumCount minus initialCount) Zeiten.

Wenn Sie eine leere Zeichenfolge angeben oder eine leere Zeichenfolge angeben nullname, wird ein lokales Semaphor erstellt, als hätten Sie die Semaphore(Int32, Int32) Konstruktorüberladung aufgerufen. In diesem Fall createdNew ist immer true.

Da benannte Semaphore im gesamten Betriebssystem sichtbar sind, können sie verwendet werden, um die Ressourcennutzung über Prozessgrenzen hinweg zu koordinieren.

Weitere Informationen

• Verwaltetes Thread-Management
• Semaphor

Quelle:

Semaphore.cs

Quelle:

Semaphore.cs

public:
 Semaphore(int initialCount, int maximumCount, System::String ^ name, System::Threading::NamedWaitHandleOptions options);

public Semaphore(int initialCount, int maximumCount, string? name, System.Threading.NamedWaitHandleOptions options);

new System.Threading.Semaphore : int * int * string * System.Threading.NamedWaitHandleOptions -> System.Threading.Semaphore

Public Sub New (initialCount As Integer, maximumCount As Integer, name As String, options As NamedWaitHandleOptions)

Parameter

Ausnahmen

Hinweise

Dieser Konstruktor initialisiert ein Semaphore Objekt, das einen benannten Systemsemaphor darstellt. Sie können mehrere Semaphore Objekte erstellen, die denselben benannten Systemsemaphor darstellen.

Wenn ein name Synchronisierungsobjekt des angeforderten Typs bereits im Namespace vorhanden ist, wird das vorhandene Synchronisierungsobjekt verwendet, es sei denn options , es wird der Zugriff auf den aktuellen Benutzer beschränkt, und das Synchronisierungsobjekt ist nicht mit dem Objekt kompatibel, in diesem Fall wird ein WaitHandleCannotBeOpenedException Auslösen ausgelöst. Wenn ein Synchronisierungsobjekt eines anderen Typs bereits im Namespace vorhanden ist, wird auch ein WaitHandleCannotBeOpenedException Fehler ausgelöst. Andernfalls wird ein neues Synchronisierungsobjekt erstellt.

Wenn der benannte System-Semaphor nicht vorhanden ist, wird es mit der anfänglichen Anzahl und der maximalen Anzahl erstellt, die durch initialCount und .maximumCount Wenn der benannte Systemsemaphor bereits vorhanden ist und initialCount nicht verwendet wird, maximumCount obwohl ungültige Werte weiterhin Ausnahmen verursachen. Wenn Sie ermitteln müssen, ob ein benanntes System-Semaphor erstellt wurde, verwenden Sie stattdessen die Semaphore(Int32, Int32, String, Boolean) Konstruktorüberladung.

Wenn Sie eine leere Zeichenfolge angeben oder eine leere Zeichenfolge angeben nullname, wird ein lokales Semaphor erstellt, als hätten Sie die Semaphore(Int32, Int32) Konstruktorüberladung aufgerufen.

Da benannte Semaphore im gesamten Betriebssystem sichtbar sind, können sie verwendet werden, um die Ressourcennutzung über Prozessgrenzen hinweg zu koordinieren.

Wenn Sie herausfinden möchten, ob ein benanntes Systemsemaphor vorhanden ist, verwenden Sie die OpenExisting Methode. Die OpenExisting Methode versucht, ein vorhandenes benanntes Semaphor zu öffnen, und löst eine Ausnahme aus, wenn das System-Semaphor nicht vorhanden ist.

Auf Windows kann options angegeben werden, um anzugeben, ob der benannte Semaphor nur für den aktuellen Benutzer oder für alle Benutzer zugänglich ist. Außerdem können Sie angeben, ob der benannte Semaphor nur für Prozesse in der aktuellen Sitzung oder für alle Sitzungen zugänglich ist. Weitere Informationen finden Sie unter NamedWaitHandleOptions.

Weitere Informationen

• Verwaltetes Thread-Management
• Semaphor

public:
 Semaphore(int initialCount, int maximumCount, System::String ^ name, [Runtime::InteropServices::Out] bool % createdNew, System::Security::AccessControl::SemaphoreSecurity ^ semaphoreSecurity);

public Semaphore(int initialCount, int maximumCount, string name, out bool createdNew, System.Security.AccessControl.SemaphoreSecurity semaphoreSecurity);

new System.Threading.Semaphore : int * int * string * bool * System.Security.AccessControl.SemaphoreSecurity -> System.Threading.Semaphore

Public Sub New (initialCount As Integer, maximumCount As Integer, name As String, ByRef createdNew As Boolean, semaphoreSecurity As SemaphoreSecurity)

Parameter

Ausnahmen

Beispiele

Im folgenden Codebeispiel wird das prozessübergreifende Verhalten eines benannten Semaphors mit Zugriffssteuerungssicherheit veranschaulicht. Im Beispiel wird die OpenExisting(String) Methodenüberladung verwendet, um das Vorhandensein eines benannten Semaphors zu testen. Wenn das Semaphor nicht vorhanden ist, wird es mit einer maximalen Anzahl von zwei und mit Zugriffssteuerungssicherheit erstellt, die dem aktuellen Benutzer das Recht auf Nutzung des Semaphors verweigert, aber das Recht gewährt, Berechtigungen für das Semaphor zu lesen und zu ändern. Wenn Sie das kompilierte Beispiel aus zwei Befehlsfenstern ausführen, löst die zweite Kopie eine Zugriffsverletzungs exception für den Aufruf der OpenExisting(String) Methode aus. Die Ausnahme wird abgefangen, und im Beispiel wird die OpenExisting(String, SemaphoreRights) Methodenüberladung verwendet, um das Semaphor mit den zum Lesen und Ändern der Berechtigungen erforderlichen Rechte zu öffnen.

Nachdem die Berechtigungen geändert wurden, wird das Semaphor mit den zum Eingeben und Freigeben erforderlichen Rechten geöffnet. Wenn Sie das kompilierte Beispiel aus einem dritten Befehlsfenster ausführen, wird es mit den neuen Berechtigungen ausgeführt.

using System;
using System.Threading;
using System.Security.AccessControl;

internal class Example
{
    internal static void Main()
    {
        const string semaphoreName = "SemaphoreExample5";

        Semaphore sem = null;
        bool doesNotExist = false;
        bool unauthorized = false;

        // Attempt to open the named semaphore.
        try
        {
            // Open the semaphore with (SemaphoreRights.Synchronize
            // | SemaphoreRights.Modify), to enter and release the
            // named semaphore.
            //
            sem = Semaphore.OpenExisting(semaphoreName);
        }
        catch(WaitHandleCannotBeOpenedException)
        {
            Console.WriteLine("Semaphore does not exist.");
            doesNotExist = true;
        }
        catch(UnauthorizedAccessException ex)
        {
            Console.WriteLine("Unauthorized access: {0}", ex.Message);
            unauthorized = true;
        }

        // There are three cases: (1) The semaphore does not exist.
        // (2) The semaphore exists, but the current user doesn't 
        // have access. (3) The semaphore exists and the user has
        // access.
        //
        if (doesNotExist)
        {
            // The semaphore does not exist, so create it.
            //
            // The value of this variable is set by the semaphore
            // constructor. It is true if the named system semaphore was
            // created, and false if the named semaphore already existed.
            //
            bool semaphoreWasCreated;

            // Create an access control list (ACL) that denies the
            // current user the right to enter or release the 
            // semaphore, but allows the right to read and change
            // security information for the semaphore.
            //
            string user = Environment.UserDomainName + "\\" 
                + Environment.UserName;
            SemaphoreSecurity semSec = new SemaphoreSecurity();

            SemaphoreAccessRule rule = new SemaphoreAccessRule(
                user, 
                SemaphoreRights.Synchronize | SemaphoreRights.Modify, 
                AccessControlType.Deny);
            semSec.AddAccessRule(rule);

            rule = new SemaphoreAccessRule(
                user, 
                SemaphoreRights.ReadPermissions | SemaphoreRights.ChangePermissions,
                AccessControlType.Allow);
            semSec.AddAccessRule(rule);

            // Create a Semaphore object that represents the system
            // semaphore named by the constant 'semaphoreName', with
            // maximum count three, initial count three, and the
            // specified security access. The Boolean value that 
            // indicates creation of the underlying system object is
            // placed in semaphoreWasCreated.
            //
            sem = new Semaphore(3, 3, semaphoreName, 
                out semaphoreWasCreated, semSec);

            // If the named system semaphore was created, it can be
            // used by the current instance of this program, even 
            // though the current user is denied access. The current
            // program enters the semaphore. Otherwise, exit the
            // program.
            // 
            if (semaphoreWasCreated)
            {
                Console.WriteLine("Created the semaphore.");
            }
            else
            {
                Console.WriteLine("Unable to create the semaphore.");
                return;
            }
        }
        else if (unauthorized)
        {
            // Open the semaphore to read and change the access
            // control security. The access control security defined
            // above allows the current user to do this.
            //
            try
            {
                sem = Semaphore.OpenExisting(
                    semaphoreName, 
                    SemaphoreRights.ReadPermissions 
                        | SemaphoreRights.ChangePermissions);

                // Get the current ACL. This requires 
                // SemaphoreRights.ReadPermissions.
                SemaphoreSecurity semSec = sem.GetAccessControl();
                
                string user = Environment.UserDomainName + "\\" 
                    + Environment.UserName;

                // First, the rule that denied the current user 
                // the right to enter and release the semaphore must
                // be removed.
                SemaphoreAccessRule rule = new SemaphoreAccessRule(
                    user, 
                    SemaphoreRights.Synchronize | SemaphoreRights.Modify, 
                    AccessControlType.Deny);
                semSec.RemoveAccessRule(rule);

                // Now grant the user the correct rights.
                // 
                rule = new SemaphoreAccessRule(user, 
                     SemaphoreRights.Synchronize | SemaphoreRights.Modify, 
                     AccessControlType.Allow);
                semSec.AddAccessRule(rule);

                // Update the ACL. This requires
                // SemaphoreRights.ChangePermissions.
                sem.SetAccessControl(semSec);

                Console.WriteLine("Updated semaphore security.");

                // Open the semaphore with (SemaphoreRights.Synchronize 
                // | SemaphoreRights.Modify), the rights required to
                // enter and release the semaphore.
                //
                sem = Semaphore.OpenExisting(semaphoreName);
            }
            catch(UnauthorizedAccessException ex)
            {
                Console.WriteLine("Unable to change permissions: {0}", ex.Message);
                return;
            }
        }

        // Enter the semaphore, and hold it until the program
        // exits.
        //
        try
        {
            sem.WaitOne();
            Console.WriteLine("Entered the semaphore.");
            Console.WriteLine("Press the Enter key to exit.");
            Console.ReadLine();
            sem.Release();
        }
        catch(UnauthorizedAccessException ex)
        {
            Console.WriteLine("Unauthorized access: {0}", ex.Message);
        }
    }
}

Imports System.Threading
Imports System.Security.AccessControl

Friend Class Example

    <MTAThread> _
    Friend Shared Sub Main()
        Const semaphoreName As String = "SemaphoreExample5"

        Dim sem As Semaphore = Nothing
        Dim doesNotExist as Boolean = False
        Dim unauthorized As Boolean = False

        ' Attempt to open the named semaphore.
        Try
            ' Open the semaphore with (SemaphoreRights.Synchronize
            ' Or SemaphoreRights.Modify), to enter and release the
            ' named semaphore.
            '
            sem = Semaphore.OpenExisting(semaphoreName)
        Catch ex As WaitHandleCannotBeOpenedException
            Console.WriteLine("Semaphore does not exist.")
            doesNotExist = True
        Catch ex As UnauthorizedAccessException
            Console.WriteLine("Unauthorized access: {0}", ex.Message)
            unauthorized = True
        End Try

        ' There are three cases: (1) The semaphore does not exist.
        ' (2) The semaphore exists, but the current user doesn't 
        ' have access. (3) The semaphore exists and the user has
        ' access.
        '
        If doesNotExist Then
            ' The semaphore does not exist, so create it.
            '
            ' The value of this variable is set by the semaphore
            ' constructor. It is True if the named system semaphore was
            ' created, and False if the named semaphore already existed.
            '
            Dim semaphoreWasCreated As Boolean

            ' Create an access control list (ACL) that denies the
            ' current user the right to enter or release the 
            ' semaphore, but allows the right to read and change
            ' security information for the semaphore.
            '
            Dim user As String = Environment.UserDomainName _ 
                & "\" & Environment.UserName
            Dim semSec As New SemaphoreSecurity()

            Dim rule As New SemaphoreAccessRule(user, _
                SemaphoreRights.Synchronize Or SemaphoreRights.Modify, _
                AccessControlType.Deny)
            semSec.AddAccessRule(rule)

            rule = New SemaphoreAccessRule(user, _
                SemaphoreRights.ReadPermissions Or _
                SemaphoreRights.ChangePermissions, _
                AccessControlType.Allow)
            semSec.AddAccessRule(rule)

            ' Create a Semaphore object that represents the system
            ' semaphore named by the constant 'semaphoreName', with
            ' maximum count three, initial count three, and the
            ' specified security access. The Boolean value that 
            ' indicates creation of the underlying system object is
            ' placed in semaphoreWasCreated.
            '
            sem = New Semaphore(3, 3, semaphoreName, _
                semaphoreWasCreated, semSec)

            ' If the named system semaphore was created, it can be
            ' used by the current instance of this program, even 
            ' though the current user is denied access. The current
            ' program enters the semaphore. Otherwise, exit the
            ' program.
            ' 
            If semaphoreWasCreated Then
                Console.WriteLine("Created the semaphore.")
            Else
                Console.WriteLine("Unable to create the semaphore.")
                Return
            End If

        ElseIf unauthorized Then

            ' Open the semaphore to read and change the access
            ' control security. The access control security defined
            ' above allows the current user to do this.
            '
            Try
                sem = Semaphore.OpenExisting(semaphoreName, _
                    SemaphoreRights.ReadPermissions Or _
                    SemaphoreRights.ChangePermissions)

                ' Get the current ACL. This requires 
                ' SemaphoreRights.ReadPermissions.
                Dim semSec As SemaphoreSecurity = sem.GetAccessControl()
                
                Dim user As String = Environment.UserDomainName _ 
                    & "\" & Environment.UserName

                ' First, the rule that denied the current user 
                ' the right to enter and release the semaphore must
                ' be removed.
                Dim rule As New SemaphoreAccessRule(user, _
                    SemaphoreRights.Synchronize Or SemaphoreRights.Modify, _
                    AccessControlType.Deny)
                semSec.RemoveAccessRule(rule)

                ' Now grant the user the correct rights.
                ' 
                rule = New SemaphoreAccessRule(user, _
                    SemaphoreRights.Synchronize Or SemaphoreRights.Modify, _
                    AccessControlType.Allow)
                semSec.AddAccessRule(rule)

                ' Update the ACL. This requires
                ' SemaphoreRights.ChangePermissions.
                sem.SetAccessControl(semSec)

                Console.WriteLine("Updated semaphore security.")

                ' Open the semaphore with (SemaphoreRights.Synchronize 
                ' Or SemaphoreRights.Modify), the rights required to
                ' enter and release the semaphore.
                '
                sem = Semaphore.OpenExisting(semaphoreName)

            Catch ex As UnauthorizedAccessException
                Console.WriteLine("Unable to change permissions: {0}", _
                    ex.Message)
                Return
            End Try

        End If

        ' Enter the semaphore, and hold it until the program
        ' exits.
        '
        Try
            sem.WaitOne()
            Console.WriteLine("Entered the semaphore.")
            Console.WriteLine("Press the Enter key to exit.")
            Console.ReadLine()
            sem.Release()
        Catch ex As UnauthorizedAccessException
            Console.WriteLine("Unauthorized access: {0}", _
                ex.Message)
        End Try
    End Sub 
End Class

Hinweise

Verwenden Sie diesen Konstruktor, um die Zugriffssteuerungssicherheit auf ein benanntes System-Semaphor anzuwenden, wenn es erstellt wird, um zu verhindern, dass anderer Code die Kontrolle über das Semaphor übernimmt.

Möglicherweise name wird dem Namespace ein Präfix vorangestellt Global\ oder Local\ angegeben. Wenn der Global Namespace angegeben ist, kann das Synchronisierungsobjekt für alle Prozesse im System freigegeben werden. Wenn der Local Namespace angegeben ist, was auch der Standardwert ist, wenn kein Namespace angegeben wird, kann das Synchronisierungsobjekt für Prozesse in derselben Sitzung freigegeben werden. Bei Windows ist eine Sitzung eine Anmeldesitzung, und Dienste werden in der Regel in einer anderen nicht interaktiven Sitzung ausgeführt. Auf Unix-ähnlichen Betriebssystemen verfügt jede Shell über eine eigene Sitzung. Sitzungslokale Synchronisierungsobjekte können für die Synchronisierung zwischen Prozessen mit einer Beziehung zwischen übergeordnetem/untergeordnetem Element geeignet sein, in der sie alle in derselben Sitzung ausgeführt werden. Weitere Informationen zu Synchronisierungsobjektnamen in Windows finden Sie unter Object Names.

Wenn ein name Synchronisierungsobjekt des angeforderten Typs bereits im Namespace vorhanden ist, wird das vorhandene Synchronisierungsobjekt verwendet. Wenn bereits ein Synchronisierungsobjekt eines anderen Typs im Namespace vorhanden ist, wird ein WaitHandleCannotBeOpenedException Fehler ausgelöst. Andernfalls wird ein neues Synchronisierungsobjekt erstellt.

Dieser Konstruktor initialisiert ein Semaphore Objekt, das einen benannten Systemsemaphor darstellt. Sie können mehrere Semaphore Objekte erstellen, die denselben benannten Systemsemaphor darstellen.

Wenn der benannte Systemsemaphor nicht vorhanden ist, wird es mit der angegebenen Zugriffssteuerungssicherheit erstellt. Wenn der benannte Semaphor vorhanden ist, wird die angegebene Zugriffssteuerungssicherheit ignoriert.

Wenn der benannte System-Semaphor nicht vorhanden ist, wird es mit der anfänglichen Anzahl und der maximalen Anzahl erstellt, die durch initialCount und .maximumCount Wenn der benannte Systemsemaphor bereits vorhanden ist und initialCount nicht verwendet wird, maximumCount obwohl ungültige Werte weiterhin Ausnahmen verursachen. Verwenden Sie den createdNew Parameter, um zu bestimmen, ob das System-Semaphor von diesem Konstruktor erstellt wurde.

Wenn initialCount sie kleiner als maximumCountist und createdNew ist, ist trueder Effekt identisch mit dem Aufruf des aktuellen Threads WaitOne (maximumCount minus initialCount) Zeiten.

Wenn Sie eine leere Zeichenfolge angeben oder eine leere Zeichenfolge angeben nullname, wird ein lokales Semaphor erstellt, als hätten Sie die Semaphore(Int32, Int32) Konstruktorüberladung aufgerufen. In diesem Fall createdNew ist immer true.

Da benannte Semaphore im gesamten Betriebssystem sichtbar sind, können sie verwendet werden, um die Ressourcennutzung über Prozessgrenzen hinweg zu koordinieren.

Weitere Informationen

• Verwaltetes Thread-Management
• Semaphor

Quelle:

Semaphore.cs

Quelle:

Semaphore.cs

public:
 Semaphore(int initialCount, int maximumCount, System::String ^ name, System::Threading::NamedWaitHandleOptions options, [Runtime::InteropServices::Out] bool % createdNew);

public Semaphore(int initialCount, int maximumCount, string? name, System.Threading.NamedWaitHandleOptions options, out bool createdNew);

new System.Threading.Semaphore : int * int * string * System.Threading.NamedWaitHandleOptions * bool -> System.Threading.Semaphore

Public Sub New (initialCount As Integer, maximumCount As Integer, name As String, options As NamedWaitHandleOptions, ByRef createdNew As Boolean)

Parameter

Ausnahmen

Hinweise

Wenn ein name Synchronisierungsobjekt des angeforderten Typs bereits im Namespace vorhanden ist, wird das vorhandene Synchronisierungsobjekt verwendet, es sei denn options , es wird der Zugriff auf den aktuellen Benutzer beschränkt, und das Synchronisierungsobjekt ist nicht mit dem Objekt kompatibel, in diesem Fall wird ein WaitHandleCannotBeOpenedException Auslösen ausgelöst. Wenn ein Synchronisierungsobjekt eines anderen Typs bereits im Namespace vorhanden ist, wird auch ein WaitHandleCannotBeOpenedException Fehler ausgelöst. Andernfalls wird ein neues Synchronisierungsobjekt erstellt.

Dieser Konstruktor initialisiert ein Semaphore Objekt, das einen benannten Systemsemaphor darstellt. Sie können mehrere Semaphore Objekte erstellen, die denselben benannten Systemsemaphor darstellen.

Wenn der benannte System-Semaphor nicht vorhanden ist, wird es mit der anfänglichen Anzahl und der maximalen Anzahl erstellt, die durch initialCount und .maximumCount Wenn der benannte Systemsemaphor bereits vorhanden ist und initialCount nicht verwendet wird, maximumCount obwohl ungültige Werte weiterhin Ausnahmen verursachen. Verwenden Sie den createdNew Parameter, um zu bestimmen, ob das System-Semaphor von diesem Konstruktor erstellt wurde.

Wenn initialCount sie kleiner als maximumCountist und createdNew ist, ist trueder Effekt identisch mit dem Aufruf des aktuellen Threads WaitOne (maximumCount minus initialCount) Zeiten.

Wenn Sie eine leere Zeichenfolge angeben oder eine leere Zeichenfolge angeben nullname, wird ein lokales Semaphor erstellt, als hätten Sie die Semaphore(Int32, Int32) Konstruktorüberladung aufgerufen. In diesem Fall createdNew ist immer true.

Da benannte Semaphore im gesamten Betriebssystem sichtbar sind, können sie verwendet werden, um die Ressourcennutzung über Prozessgrenzen hinweg zu koordinieren.

Auf Windows kann options angegeben werden, um anzugeben, ob der benannte Semaphor nur für den aktuellen Benutzer oder für alle Benutzer zugänglich ist. Außerdem können Sie angeben, ob der benannte Semaphor nur für Prozesse in der aktuellen Sitzung oder für alle Sitzungen zugänglich ist. Weitere Informationen finden Sie unter NamedWaitHandleOptions.

Weitere Informationen

• Verwaltetes Thread-Management
• Semaphor