CyclicBarrier Klasse

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, mit der eine Reihe von Threads alle aufeinander warten können, um einen gemeinsamen Sperrpunkt zu erreichen.

[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

JavaObject

Object
CyclicBarrier

Attribute: RegisterAttribute

Hinweise

Eine Synchronisierungshilfe, mit der eine Reihe von Threads alle aufeinander warten können, um einen gemeinsamen Sperrpunkt zu erreichen. CyclicBarrier sind nützlich in Programmen, die eine feste Party von Threads umfassen, die gelegentlich auf einander warten müssen. Die Barriere wird als em-zyklische< bezeichnet>, da sie nach der Freigabe der Wartethreads wiederverwendet werden kann.

A CyclicBarrier supports an optional Runnable command that is run once per barrier point, after the last thread in the party arrives, but before any threads are released. Diese <Em-Barriere-Aktion> ist nützlich, um den gemeinsam genutzten Zustand 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 die Zeilen zusammengeführt. Wenn die Fusion feststellt, dass eine Lösung gefunden wurde, done() wird diese zurückgegeben true , und jeder Arbeitnehmer wird beendet.

Wenn die Barriereaktion nicht darauf angewiesen ist, dass die Parteien ausgesetzt werden, wenn sie ausgeführt wird, kann jeder der Threads in der Partei diese Aktion ausführen, wenn sie freigegeben wird. Um dies zu erleichtern, gibt jeder Aufruf des #await Ankunftsindex 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
            }}

Die CyclicBarrier Verwendung eines All-or-None-Unterbrechungsmodells für fehlgeschlagene Synchronisierungsversuche: Wenn ein Thread aufgrund von Unterbrechungen, Fehlern oder Timeout vorzeitig einen Sperrpunkt verlässt, bleiben alle anderen Threads, die an diesem Sperrpunkt warten, ebenfalls ungewöhnlich BrokenBarrierException (oder InterruptedException wenn sie gleichzeitig unterbrochen wurden).

Auswirkungen auf die Speicherkonsistenz: Aktionen in einem Thread vor dem Aufrufen await()<von "i>happen-before "-Aktionen, die Teil der Barriereaktion sind, die wiederum nach einer erfolgreichen Rückgabe von den entsprechenden await() in anderen Threads ausgeführt werden.

Hinzugefügt in 1.5.

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

Teile dieser Seite sind Änderungen auf der Grundlage von Arbeiten, die vom Android Open Source-Projekt erstellt und freigegeben werden und gemäß den in der Creative Commons 2.5 Attribution License beschriebenen Begriffen verwendet werden.

Konstruktoren

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

Eigenschaften

Name	Beschreibung
Class	Gibt die Laufzeitklasse dieses Werts `Object`zurück. (Geerbt von Object)
Handle	Das Handle für die zugrunde liegende Android-Instanz. (Geerbt von Object)
IsBroken	Fragt ab, ob sich diese Barriere in einem fehlerhaften Zustand befindet.
JniIdentityHashCode	Ruft den Identitätshashcode ab, der diesem Java Peer von der Interop-Laufzeit zugewiesen ist. (Geerbt von Object)
JniManagedPeerState	Eine Synchronisierungshilfe, mit der eine Reihe von Threads alle aufeinander warten können, um einen gemeinsamen Sperrpunkt zu erreichen. (Geerbt von JavaObject)
JniPeerMembers	Eine Synchronisierungshilfe, mit der eine Reihe von Threads alle aufeinander warten können, um einen gemeinsamen Sperrpunkt zu erreichen.
NumberWaiting	Gibt die Anzahl der Parteien zurück, die derzeit auf die Barriere warten.
Parties	Gibt die Anzahl der Parteien zurück, die zum Reisen dieser Barriere erforderlich sind.
PeerReference	Ruft den JNI-Objektverweis für diesen Java Peer ab. (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

Name	Beschreibung
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()	Wartet asynchron, bis alle Parteien auf diese Barriere aufgerufen `await` haben.
AwaitAsync(Int64, TimeUnit)	Wartet asynchron, bis alle Parteien auf diese Barriere aufgerufen `await` haben.
Clone()	Erstellt und gibt eine Kopie dieses Objekts zurück. (Geerbt von Object)
Construct(JniObjectReference, JniObjectReferenceOptions)	Eine Synchronisierungshilfe, mit der eine Reihe von Threads alle aufeinander warten können, um einen gemeinsamen Sperrpunkt zu erreichen. (Geerbt von JavaObject)
Dispose()	Veröffentlicht die Ressourcen, die von diesem Java Peer gehalten werden. (Geerbt von Object)
Dispose(Boolean)	Veröffentlicht die Ressourcen, die von diesem Java Peer gehalten werden. (Geerbt von Object)
DisposeUnlessReferenced()	Eine Synchronisierungshilfe, mit der eine Reihe von Threads alle aufeinander warten können, um einen gemeinsamen Sperrpunkt zu erreichen. (Geerbt von JavaObject)
Equals(Object)	Eine Synchronisierungshilfe, mit der eine Reihe von Threads alle aufeinander warten können, um einen gemeinsamen Sperrpunkt zu erreichen. (Geerbt von JavaObject)
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 bestimmt, dass keine weiteren Verweise auf das Objekt vorhanden sind. (Geerbt von Object)
Notify()	Aktiviert einen einzelnen Thread, der auf dem Monitor dieses Objekts wartet. (Geerbt von Object)
NotifyAll()	Aktiviert alle Threads, die auf dem Monitor dieses Objekts warten. (Geerbt von Object)
Reset()	Setzt die Barriere auf den ursprünglichen Zustand zurück.
SetHandle(IntPtr, JniHandleOwnership)	Legt die Handle-Eigenschaft fest. (Geerbt von Object)
SetPeerReference(JniObjectReference, JniObjectReferenceOptions)	Eine Synchronisierungshilfe, mit der eine Reihe von Threads alle aufeinander warten können, um einen gemeinsamen Sperrpunkt zu erreichen. (Geerbt von JavaObject)
ToArray<T>()	Erstellt ein verwaltetes Array aus diesem Java Arraywrapper. (Geerbt von Object)
ToString()	Gibt eine Zeichenfolgendarstellung des Objekts zurück. (Geerbt von Object)
UnregisterFromRuntime()	Hebt die Registrierung dieses Java Peers aus der Interop-Laufzeit auf. (Geerbt von Object)
Wait()	Bewirkt, dass der aktuelle Thread wartet, bis er wach ist, in der Regel durch em benachrichtigt/em< oder >em<unterbrochen>/em<.><> (Geerbt von Object)
Wait(Int64, Int32)	Bewirkt, dass der aktuelle Thread wartet, bis er wach ist, in der Regel durch <em>benachrichtigt</em> oder <em>unterbrochen</em> oder bis eine bestimmte Menge an Echtzeit verstrichen ist. (Geerbt von Object)
Wait(Int64)	Bewirkt, dass der aktuelle Thread wartet, bis er wach ist, in der Regel durch <em>benachrichtigt</em> oder <em>unterbrochen</em> oder bis eine bestimmte Menge an Echtzeit verstrichen ist. (Geerbt von Object)

Explizite Schnittstellenimplementierungen

Name	Beschreibung
IJavaPeerable.Disposed()	Eine Synchronisierungshilfe, mit der eine Reihe von Threads alle aufeinander warten können, um einen gemeinsamen Sperrpunkt zu erreichen. (Geerbt von JavaObject)
IJavaPeerable.Finalized()	Eine Synchronisierungshilfe, mit der eine Reihe von Threads alle aufeinander warten können, um einen gemeinsamen Sperrpunkt zu erreichen. (Geerbt von JavaObject)
IJavaPeerable.JniObjectReferenceControlBlock	Eine Synchronisierungshilfe, mit der eine Reihe von Threads alle aufeinander warten können, um einen gemeinsamen Sperrpunkt zu erreichen. (Geerbt von JavaObject)
IJavaPeerable.SetJniIdentityHashCode(Int32)	Eine Synchronisierungshilfe, mit der eine Reihe von Threads alle aufeinander warten können, um einen gemeinsamen Sperrpunkt zu erreichen. (Geerbt von JavaObject)
IJavaPeerable.SetJniManagedPeerState(JniManagedPeerStates)	Eine Synchronisierungshilfe, mit der eine Reihe von Threads alle aufeinander warten können, um einen gemeinsamen Sperrpunkt zu erreichen. (Geerbt von JavaObject)
IJavaPeerable.SetPeerReference(JniObjectReference)	Eine Synchronisierungshilfe, mit der eine Reihe von Threads alle aufeinander warten können, um einen gemeinsamen Sperrpunkt zu erreichen. (Geerbt von JavaObject)

Erweiterungsmethoden

Name	Beschreibung
GetJniTypeName(IJavaPeerable)	Ruft den JNI-Namen des Typs der Instanz `self`ab.
JavaAs<TResult>(IJavaPeerable)	Versuchen Sie, die Eingabe `self`zu `TResult` erzwingen, und überprüfen Sie, ob die Koersion auf der Java Seite gültig ist.
JavaCast<TResult>(IJavaObject)	Führt eine android-laufzeitgecheckte Typkonvertierung aus.
JavaCast<TResult>(IJavaObject)	Eine Synchronisierungshilfe, mit der eine Reihe von Threads alle aufeinander warten können, um einen gemeinsamen Sperrpunkt zu erreichen.
TryJavaCast<TResult>(IJavaPeerable, TResult)	Versuchen Sie, die Eingabe `self`zu `TResult` erzwingen, und überprüfen Sie, ob die Koersion auf der Java Seite gültig ist.

Gilt für: