ExecutorCompletionService Klasse
Definition
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.
A CompletionService that uses a supplied Executor to execute tasks.
[Android.Runtime.Register("java/util/concurrent/ExecutorCompletionService", DoNotGenerateAcw=true)]
[Java.Interop.JavaTypeParameters(new System.String[] { "V" })]
public class ExecutorCompletionService : Java.Lang.Object, IDisposable, Java.Interop.IJavaPeerable, Java.Util.Concurrent.ICompletionService[<Android.Runtime.Register("java/util/concurrent/ExecutorCompletionService", DoNotGenerateAcw=true)>]
[<Java.Interop.JavaTypeParameters(new System.String[] { "V" })>]
type ExecutorCompletionService = class
inherit Object
interface ICompletionService
interface IJavaObject
interface IDisposable
interface IJavaPeerable- Vererbung
- Attribute
- Implementiert
Hinweise
A CompletionService that uses a supplied Executor to execute tasks. Diese Klasse ordnet an, dass übermittelte Aufgaben nach Abschluss in einer Warteschlange platziert werden, auf die zugegriffen werden kann take. Die Klasse ist leicht genug, um für die vorübergehende Verwendung bei der Verarbeitung von Aufgabengruppen geeignet zu sein.
<b>Verwendungsbeispiele.</b>
Angenommen, Sie haben eine Reihe von Solvern für ein bestimmtes Problem, jeder gibt einen Wert eines bestimmten Typs Resultzurück und möchte sie gleichzeitig ausführen und die Ergebnisse jeder davon verarbeiten, die einen Wert ungleich Null zurückgeben, in einigen Methoden use(Result r). Sie könnten folgendes schreiben:
{@code
void solve(Executor e,
Collection<Callable<Result>> solvers)
throws InterruptedException, ExecutionException {
CompletionService<Result> cs
= new ExecutorCompletionService<>(e);
solvers.forEach(cs::submit);
for (int i = solvers.size(); i > 0; i--) {
Result r = cs.take().get();
if (r != null)
use(r);
}
}}
Angenommen, Sie möchten stattdessen das erste Nicht-Null-Ergebnis der Gruppe von Vorgängen verwenden, alle auf Ausnahmen stoßen, und alle anderen Aufgaben abbrechen, wenn das erste bereit ist:
{@code
void solve(Executor e,
Collection<Callable<Result>> solvers)
throws InterruptedException {
CompletionService<Result> cs
= new ExecutorCompletionService<>(e);
int n = solvers.size();
List<Future<Result>> futures = new ArrayList<>(n);
Result result = null;
try {
solvers.forEach(solver -> futures.add(cs.submit(solver)));
for (int i = n; i > 0; i--) {
try {
Result r = cs.take().get();
if (r != null) {
result = r;
break;
}
} catch (ExecutionException ignore) {}
}
} finally {
futures.forEach(future -> future.cancel(true));
}
if (result != null)
use(result);
}}
Hinzugefügt in 1.5.
Java-Dokumentation für java.util.concurrent.ExecutorCompletionService.
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
| ExecutorCompletionService(IExecutor) |
Erstellt einen ExecutorCompletionService mithilfe des bereitgestellten Executors für die Ausführung der Basisaufgabe und eine |
| ExecutorCompletionService(IExecutor, IBlockingQueue) |
Erstellt einen ExecutorCompletionService mit dem bereitgestellten Executor für die Ausführung der Basisaufgabe und der bereitgestellten Warteschlange als Abschlusswarteschlange. |
| ExecutorCompletionService(IntPtr, JniHandleOwnership) |
Ein Konstruktor, der beim Erstellen verwalteter Darstellungen von JNI-Objekten verwendet wird; wird von der Laufzeit aufgerufen. |
Eigenschaften
| Class |
Gibt die Laufzeitklasse dieses Werts |
| Handle |
Das Handle für die zugrunde liegende Android-Instanz. (Geerbt von Object) |
| JniIdentityHashCode |
A |
| JniPeerMembers |
A |
| PeerReference |
A |
| 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
| Clone() |
Erstellt und gibt eine Kopie dieses Objekts zurück. (Geerbt von Object) |
| Dispose() |
A |
| Dispose(Boolean) |
A |
| 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) |
| Poll() |
Ruft die Zukunft ab, die die nächste abgeschlossene Aufgabe darstellt, oder entfernt sie, wenn |
| Poll(Int64, TimeUnit) |
Ruft die Zukunft ab, die die nächste abgeschlossene Aufgabe darstellt, und entfernt sie, falls erforderlich, bis zur angegebenen Wartezeit, wenn noch keine vorhanden ist. |
| PollAsync() |
A |
| PollAsync(Int64, TimeUnit) |
A |
| SetHandle(IntPtr, JniHandleOwnership) |
Legt die Handle-Eigenschaft fest. (Geerbt von Object) |
| Submit(ICallable) |
A |
| Submit(IRunnable, Object) |
A |
| Take() |
Ruft die Zukunft ab, die die nächste abgeschlossene Aufgabe darstellt, und entfernt sie, wenn noch keine vorhanden ist. |
| TakeAsync() |
A |
| ToArray<T>() |
A |
| ToString() |
Gibt eine Zeichenfolgendarstellung des Objekts zurück. (Geerbt von Object) |
| UnregisterFromRuntime() |
A |
| 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) |
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, 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) |
Explizite Schnittstellenimplementierungen
| IJavaPeerable.Disposed() |
A |
| IJavaPeerable.DisposeUnlessReferenced() |
A |
| IJavaPeerable.Finalized() |
A |
| IJavaPeerable.JniManagedPeerState |
A |
| IJavaPeerable.SetJniIdentityHashCode(Int32) |
A |
| IJavaPeerable.SetJniManagedPeerState(JniManagedPeerStates) |
A |
| IJavaPeerable.SetPeerReference(JniObjectReference) |
A |
Erweiterungsmethoden
| JavaCast<TResult>(IJavaObject) |
Führt eine android-laufzeitgecheckte Typkonvertierung aus. |
| JavaCast<TResult>(IJavaObject) |
A |
| GetJniTypeName(IJavaPeerable) |
A |