ExecutorCompletionService 클래스

정의

[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

상속

Object

Object

ExecutorCompletionService

특성

RegisterAttribute JavaTypeParametersAttribute

구현

IJavaObject IJavaPeerable ICompletionService IDisposable

설명

제공된 Executor 작업을 실행하는 데 사용하는 A CompletionService 입니다. 이 클래스는 완료 시 제출된 작업이 다음을 사용하여 take액세스할 수 있는 큐에 배치되도록 정렬합니다. 클래스는 작업 그룹을 처리할 때 일시적인 사용에 적합할 정도로 가볍습니다.

<b>사용 예제입니다.</b>

특정 문제에 대한 해결기 집합이 있고 각각 일부 형식 Result의 값을 반환하고 동시에 실행하여 null이 아닌 값을 반환하는 각각의 결과를 일부 메서드 use(Result r)에서 처리한다고 가정합니다. 다음과 같이 작성할 수 있습니다.

{@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);
              }
            }}

대신 작업 집합의 첫 번째 null이 아닌 결과를 사용하고, 예외가 발생하는 결과를 무시하고, 첫 번째 작업이 준비되면 다른 모든 작업을 취소한다고 가정합니다.

{@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);
            }}

1.5에 추가되었습니다.

에 대한 java.util.concurrent.ExecutorCompletionServiceJava 설명서

이 페이지의 일부는 Android 오픈 소스 프로젝트에서 만들고 공유하고 Creative Commons 2.5 특성 라이선스에 설명된 용어에 따라 사용되는 작업을 기반으로 하는 수정 사항입니다.

생성자

속성

메서드

명시적 인터페이스 구현

확장 메서드

적용 대상