CyclicBarrier Klasse

Referenz

Definition

Namespace:: Java.Util.Concurrent

Assembly:: Mono.Android.dll

Wichtig

Einige Informationen beziehen sich auf Vorabversionen, die vor dem Release ggf. grundlegend überarbeitet werden. Microsoft übernimmt hinsichtlich der hier bereitgestellten Informationen keine Gewährleistungen, seien sie ausdrücklich oder konkludent.

Eine Synchronisierungshilfe, die es einer Reihe von Threads ermöglicht, darauf zu warten, dass sich gegenseitig ein gemeinsamer Sperrpunkt erreicht.

[Android.Runtime.Register("java/util/concurrent/CyclicBarrier", DoNotGenerateAcw=true)]
public class CyclicBarrier : Java.Lang.Object

[<Android.Runtime.Register("java/util/concurrent/CyclicBarrier", DoNotGenerateAcw=true)>]
type CyclicBarrier = class
    inherit Object

Vererbung: Object

Object
CyclicBarrier

Attribute: RegisterAttribute

Hinweise

Eine Synchronisierungshilfe, die es einer Reihe von Threads ermöglicht, darauf zu warten, dass sich gegenseitig ein gemeinsamer Sperrpunkt erreicht. CyclicBarrier sind nützlich in Programmen, die eine gruppe von Threads mit fester Größe enthalten, die gelegentlich aufeinander warten müssen. Die Barriere wird als em>cyclic bezeichnet<, da sie wiederverwendet werden kann, nachdem die wartenden Threads losgelassen wurden.

Ein CyclicBarrier unterstützt einen optionalen Runnable Befehl, der einmal pro Sperrpunkt ausgeführt wird, nachdem der letzte Thread in der Partei eingetroffen ist, aber bevor Threads freigegeben werden. Diese barrier action ist nützlich, um shared-state zu aktualisieren, bevor eine der Parteien fortgesetzt wird.

Beispielverwendung: Hier ist ein Beispiel für die Verwendung einer Barriere in einem parallelen Analyseentwurf:

{@code
            class Solver {
              final int N;
              final float[][] data;
              final CyclicBarrier barrier;

              class Worker implements Runnable {
                int myRow;
                Worker(int row) { myRow = row; }
                public void run() {
                  while (!done()) {
                    processRow(myRow);

                    try {
                      barrier.await();
                    } catch (InterruptedException ex) {
                      return;
                    } catch (BrokenBarrierException ex) {
                      return;
                    }
                  }
                }
              }

              public Solver(float[][] matrix) {
                data = matrix;
                N = matrix.length;
                Runnable barrierAction = () -> mergeRows(...);
                barrier = new CyclicBarrier(N, barrierAction);

                List<Thread> threads = new ArrayList<>(N);
                for (int i = 0; i < N; i++) {
                  Thread thread = new Thread(new Worker(i));
                  threads.add(thread);
                  thread.start();
                }

                // wait until done
                for (Thread thread : threads)
                  try {
                    thread.join();
                  } catch (InterruptedException ex) { }
              }
            }}

Hier verarbeitet jeder Arbeitsthread eine Zeile der Matrix und wartet dann an der Barriere, bis alle Zeilen verarbeitet wurden. Wenn alle Zeilen verarbeitet werden, wird die angegebene Runnable Barriereaktion ausgeführt und führt die Zeilen zusammen. Wenn die Fusion feststellt, dass eine Lösung gefunden done() wurde, wird zurückgegeben true , und jeder Worker wird beendet.

Wenn die Barriereaktion nicht davon abhängt, dass die Parteien bei der Ausführung angehalten werden, kann jeder der Threads in der Partei diese Aktion ausführen, wenn sie freigegeben wird. Um dies zu erleichtern, gibt jeder Aufruf von #await den Eingangsindex dieses Threads an der Barriere zurück. Sie können dann auswählen, welcher Thread die Barriereaktion ausführen soll, z. B.:

{@code
            if (barrier.await() == 0) {
              // log the completion of this iteration
            }}

CyclicBarrier Verwendet ein All-or-None-Breakage-Modell für fehlgeschlagene Synchronisierungsversuche: Wenn ein Thread einen Sperrpunkt aufgrund einer Unterbrechung, eines Fehlers oder eines Timeouts vorzeitig verlässt, verlassen alle anderen Threads, die an diesem Barrierenpunkt warten, ebenfalls ungewöhnlich über BrokenBarrierException (oder InterruptedException wenn sie etwa gleichzeitig unterbrochen wurden).

Speicherkonsistenzeffekte: Aktionen in einem Thread vor dem Aufrufen await()<von i>happen-before</i-Aktionen> , die Teil der Barriereaktion sind, die wiederum vor Aktionen erfolgen, die nach einer erfolgreichen Rückgabe des entsprechenden await() in anderen Threads erfolgen.

Hinzugefügt in 1.5.

Java-Dokumentation für java.util.concurrent.CyclicBarrier.

Teile dieser Seite sind Änderungen, die auf Arbeiten basieren, die vom Android Open Source Project erstellt und freigegeben wurden und gemäß den In Attribution License beschriebenen Begriffen verwendet werden.

Konstruktoren

CyclicBarrier(Int32)	Erstellt eine neue `CyclicBarrier` , die ausgibt, wenn die angegebene Anzahl von Parteien (Threads) darauf wartet, und führt keine vordefinierte Aktion aus, wenn die Barriere übersprungen wird.
CyclicBarrier(Int32, IRunnable)	Erstellt eine neue `CyclicBarrier` , die ausgibt, wenn die angegebene Anzahl von Parteien (Threads) darauf wartet, und die die angegebene Barriereaktion ausführt, wenn die Barriere durch den letzten Thread, der in die Barriere eintritt, ausgeführt wird.
CyclicBarrier(IntPtr, JniHandleOwnership)	Ein Konstruktor, der beim Erstellen verwalteter Darstellungen von JNI-Objekten verwendet wird; wird von der Runtime aufgerufen.

Eigenschaften

Class	Gibt die Laufzeitklasse dieses `Object`zurück. (Geerbt von Object)
Handle	Das Handle für die zugrunde liegende Android-instance. (Geerbt von Object)
IsBroken	Fragt ab, ob sich diese Barriere in einem fehlerhaften Zustand befindet.
JniIdentityHashCode	Eine Synchronisierungshilfe, die es einer Reihe von Threads ermöglicht, darauf zu warten, dass sich gegenseitig ein gemeinsamer Sperrpunkt erreicht. (Geerbt von Object)
JniPeerMembers	Eine Synchronisierungshilfe, die es einer Reihe von Threads ermöglicht, darauf zu warten, dass sich gegenseitig ein gemeinsamer Sperrpunkt erreicht.
NumberWaiting	Gibt die Anzahl der Parteien zurück, die derzeit an der Barriere warten.
Parties	Gibt die Anzahl der Parteien zurück, die zum Überwinden dieser Barriere erforderlich sind.
PeerReference	Eine Synchronisierungshilfe, die es einer Reihe von Threads ermöglicht, darauf zu warten, dass sich gegenseitig ein gemeinsamer Sperrpunkt erreicht. (Geerbt von Object)
ThresholdClass	Diese API unterstützt die Mono für Android-Infrastruktur und ist nicht für die direkte Verwendung aus Ihrem Code vorgesehen.
ThresholdType	Diese API unterstützt die Mono für Android-Infrastruktur und ist nicht für die direkte Verwendung aus Ihrem Code vorgesehen.

Methoden

Await()	Wartet, bis alle #getParties Parteien diese Barriere aufgerufen `await` haben.
Await(Int64, TimeUnit)	Wartet, bis alle #getParties Parteien diese Barriere aufgerufen `await` haben oder die angegebene Wartezeit verstrichen ist.
AwaitAsync()	Eine Synchronisierungshilfe, die es einer Reihe von Threads ermöglicht, darauf zu warten, dass sich gegenseitig ein gemeinsamer Sperrpunkt erreicht.
AwaitAsync(Int64, TimeUnit)	Eine Synchronisierungshilfe, die es einer Reihe von Threads ermöglicht, darauf zu warten, dass sich gegenseitig ein gemeinsamer Sperrpunkt erreicht.
Clone()	Erstellt und gibt eine Kopie dieses Objekts zurück. (Geerbt von Object)
Dispose()	Eine Synchronisierungshilfe, die es einer Reihe von Threads ermöglicht, darauf zu warten, dass sich gegenseitig ein gemeinsamer Sperrpunkt erreicht. (Geerbt von Object)
Dispose(Boolean)	Eine Synchronisierungshilfe, die es einer Reihe von Threads ermöglicht, darauf zu warten, dass sich gegenseitig ein gemeinsamer Sperrpunkt erreicht. (Geerbt von Object)
Equals(Object)	Gibt an, ob ein anderes Objekt "gleich" diesem objekt ist. (Geerbt von Object)
GetHashCode()	Gibt einen Hashcodewert für das Objekt zurück. (Geerbt von Object)
JavaFinalize()	Wird vom Garbage Collector für ein Objekt aufgerufen, wenn die Garbage Collection feststellt, dass keine Verweise mehr auf das Objekt vorhanden sind. (Geerbt von Object)
Notify()	Aktiviert einen einzelnen Thread, der auf den Monitor dieses Objekts wartet. (Geerbt von Object)
NotifyAll()	Aktiviert alle Threads, die auf den Monitor dieses Objekts warten. (Geerbt von Object)
Reset()	Setzt die Barriere auf ihren Ursprünglichen Zustand zurück.
SetHandle(IntPtr, JniHandleOwnership)	Legt die Handle-Eigenschaft fest. (Geerbt von Object)
ToArray<T>()	Eine Synchronisierungshilfe, die es einer Reihe von Threads ermöglicht, darauf zu warten, dass sich gegenseitig ein gemeinsamer Sperrpunkt erreicht. (Geerbt von Object)
ToString()	Gibt eine Zeichenfolgendarstellung des Objekts zurück. (Geerbt von Object)
UnregisterFromRuntime()	Eine Synchronisierungshilfe, die es einer Reihe von Threads ermöglicht, darauf zu warten, dass sich gegenseitig ein gemeinsamer Sperrpunkt erreicht. (Geerbt von Object)
Wait()	Bewirkt, dass der aktuelle Thread wartet, bis er aktiviert ist, in der Regel durch <>Benachrichtigung</em> oder <em>interrupted</em>. (Geerbt von Object)
Wait(Int64)	Bewirkt, dass der aktuelle Thread wartet, bis er aktiviert ist, in der Regel durch>< Benachrichtigung</em> oder <em>interrupted</em>, oder bis eine bestimmte Menge an Echtzeit verstrichen ist. (Geerbt von Object)
Wait(Int64, Int32)	Bewirkt, dass der aktuelle Thread wartet, bis er aktiviert ist, in der Regel durch>< Benachrichtigung</em> oder <em>interrupted</em>, oder bis eine bestimmte Menge an Echtzeit verstrichen ist. (Geerbt von Object)

Explizite Schnittstellenimplementierungen

IJavaPeerable.Disposed()	Eine Synchronisierungshilfe, die es einer Reihe von Threads ermöglicht, darauf zu warten, dass sich gegenseitig ein gemeinsamer Sperrpunkt erreicht. (Geerbt von Object)
IJavaPeerable.DisposeUnlessReferenced()	Eine Synchronisierungshilfe, die es einer Reihe von Threads ermöglicht, darauf zu warten, dass sich gegenseitig ein gemeinsamer Sperrpunkt erreicht. (Geerbt von Object)
IJavaPeerable.Finalized()	Eine Synchronisierungshilfe, die es einer Reihe von Threads ermöglicht, darauf zu warten, dass sich gegenseitig ein gemeinsamer Sperrpunkt erreicht. (Geerbt von Object)
IJavaPeerable.JniManagedPeerState	Eine Synchronisierungshilfe, die es einer Reihe von Threads ermöglicht, darauf zu warten, dass sich gegenseitig ein gemeinsamer Sperrpunkt erreicht. (Geerbt von Object)
IJavaPeerable.SetJniIdentityHashCode(Int32)	Eine Synchronisierungshilfe, die es einer Reihe von Threads ermöglicht, darauf zu warten, dass sich gegenseitig ein gemeinsamer Sperrpunkt erreicht. (Geerbt von Object)
IJavaPeerable.SetJniManagedPeerState(JniManagedPeerStates)	Eine Synchronisierungshilfe, die es einer Reihe von Threads ermöglicht, darauf zu warten, dass sich gegenseitig ein gemeinsamer Sperrpunkt erreicht. (Geerbt von Object)
IJavaPeerable.SetPeerReference(JniObjectReference)	Eine Synchronisierungshilfe, die es einer Reihe von Threads ermöglicht, darauf zu warten, dass sich gegenseitig ein gemeinsamer Sperrpunkt erreicht. (Geerbt von Object)

Erweiterungsmethoden

JavaCast<TResult>(IJavaObject)	Führt eine Typkonvertierung mit Überprüfung der Android-Laufzeit aus.
JavaCast<TResult>(IJavaObject)	Eine Synchronisierungshilfe, die es einer Reihe von Threads ermöglicht, darauf zu warten, dass sich gegenseitig ein gemeinsamer Sperrpunkt erreicht.
GetJniTypeName(IJavaPeerable)	Eine Synchronisierungshilfe, die es einer Reihe von Threads ermöglicht, darauf zu warten, dass sich gegenseitig ein gemeinsamer Sperrpunkt erreicht.

Gilt für: