패키지 java.util.concurrent

보통, 유틸리티 클래스는 병행 프로그래밍으로 유용합니다.

참조처:
설명

인터페이스 개요

BlockingQueue<E>	요소의 취득시에 큐가 빌 때까지 대기하거나 요소의 포함시에 큐내의 공간이 이용 가능하게 될 때까지 대기하는 조작을 추가 지원하는 Queue .
Callable<V>	결과를 돌려주는 태스크.
CompletionService<V>	새로운 비동기 태스크의 생성을 완료필 태스크의 결과의 소비로부터 분리하는 서비스.
ConcurrentMap<K, V>	추가의 원자적 putIfAbsent, remove, replace 메서드를 제공하는 Map .
Delayed	지정된 지연 후에 동작하는 객체를 마크하기 위한, 혼합 스타일의 인터페이스이 인터페이스의 구현은, getDelay 메서드와 정합성이 있는 순서를 제공하는 compareTo 메서드를 정의해야 합니다.
Executor	송신된 Runnable 태스크를 실행하는 객체.
ExecutorService	종료를 관리하는 메서드 및 1개 이상의 비동기 태스크의 진행 상황을 추적하는 Future를 생성 가능한 메서드를 제공하는 Executor .
Future<V>	Future는 비동기 계산의 결과를 나타냅니다.
RejectedExecutionHandler	ThreadPoolExecutor 로 실행 불가능한 태스크의 핸들러
ScheduledExecutorService	지정된 지연 시간 후, 또는 주기적으로 커멘드의 실행을 스케줄 가능한 ExecutorService .
ScheduledFuture<V>	취소해 가능한, 지연 된 결과 생성 액션.
ThreadFactory	요구에 응해 새로운 thread를 작성하는 객체.

클래스 개요

AbstractExecutorService	ExecutorService 실행 메서드의 디폴트 구현을 제공합니다.
ArrayBlockingQueue<E>	배열에 근거하는 바운드 형식블록 큐 .
ConcurrentHashMap<K, V>	취득의 완전한 동시성 및 예상되는 조정 가능한 갱신 동시성을 지원하는 해시 테이블.
ConcurrentLinkedQueue<E>	안 바운드 형식의 thread 세이프인 큐 베이스의 링크 노드.
CopyOnWriteArrayList<E>	기본으로 되는 배열의 새로운 복사본을 작성함으로써 모든 변경 조작 (추가 설정등)이 구현되는 ArrayList thread 세이프인 변수입니다.
CopyOnWriteArraySet<E>	모든 조작으로 CopyOnWriteArrayList를 사용하는 Set .
CountDownLatch	다른 thread로 실행중의 조작 세트가 완료할 때까지, 1개 이상의 thread를 대기 가능하게 하는 동기 지원.
CyclicBarrier	thread 세트의 각각이 공통의 바리어 포인트에 이를 때까지 대기하는 것을 가능하게 하는 동기화 지원 기능.
DelayQueue<E extends Delayed>	Delayed 요소의 안 바운드 형식블록 큐 .
Exchanger<V>	2개의 thread가 객체를 교환 가능한 동기 포인트.
ExecutorCompletionService<V>	태스크의 실행으로 지정된 Executor를 사용하는 CompletionService .
Executors	이 패키지로 정의된 Executor, ExecutorService, ScheduledExecutorService, ThreadFactory 및 Callable 클래스용의 팩토리 및 유틸리티 메서드.
FutureTask<V>	취소해 가능한 비동기 계산.
LinkedBlockingQueue<E>	링크 노드에 근거하는 옵션의 바운드 형식블록 큐 .
PriorityBlockingQueue<E>	PriorityQueue 클래스와 같은 순서부 규칙을 사용해, 블록 취득 조작을 제공하는 안 바운드 형식블록 큐 .
ScheduledThreadPoolExecutor	지정된 지연 후 또는 주기적으로 실행하기 위한 커멘드를 추가 스케줄 가능한 ThreadPoolExecutor .
Semaphore	카운트에 사용되는 semaphore.
SynchronousQueue<E>	각 put가 take를 대기해, 그 역도 실행할 필요가 있는블록 큐 .
ThreadPoolExecutor	많은 경우, 풀 된 복수의 thread의 어느쪽이든을 사용해, 송신된 각 태스크를 실행하는 ExecutorService .
ThreadPoolExecutor.AbortPolicy	RejectedExecutionException을 Throw 한다, 거부된 태스크의 핸들러.
ThreadPoolExecutor.CallerRunsPolicy	executor가 셧다운 하고 있지 않는 경우에 execute 메서드의 thread 호출로 거부된 태스크를 직접 실행한다, 거부된 태스크의 핸들러.
ThreadPoolExecutor.DiscardOldestPolicy	executor가 셧다운 하고 있지 않는 경우에 가장 낡은 미처리의 요구를 파기해 execute를 재시행한다, 거부된 태스크의 핸들러.
ThreadPoolExecutor.DiscardPolicy	거부된 태스크를 예고 없이 파기한다, 거부된 태스크의 핸들러.

열거형의 개요

TimeUnit

TimeUnit는 기간이 지정된 입도 단위로 나타냅니다.

예외 개요

BrokenBarrierException	고장 상태에 있는지, thread의 대기중에 고장 상태에 들어가는 바리어를, thread가 대기하려고 하고 있을 때 발생되는 예외입니다.
CancellationException	태스크가 삭제되었기 때문에 FutureTask 등의 값을 생성하는 태스크의 결과를 취득할 수 없는 것을 나타내는 예외.
ExecutionException	예외의 Throw에 의해 중단된 태스크의 결과를 취득하려고 했을 때에 발생되는 예외.
RejectedExecutionException	태스크를 받아들여 실행할 수 없는 경우에 Executor 에 의해 발생되는 예외
TimeoutException	블록 조작이 타임 아웃 했을 때에 발생되는 예외.

패키지 java.util.concurrent 설명

보통, 유틸리티 클래스는 병행 프로그래밍으로 유용합니다. 이 패키지에는 몇개의 소규모의 표준화 된 확장 가능 체제 및 편리성이 높고, 다른 점에서는 단조로워 구현의 곤란한 기능을 제공하는 클래스가 포함됩니다. 이하에 주요 컴퍼넌트에 대해 간결하게 설명합니다. locks 및 atomic 패키지도 참조하십시오.

Executor

인터페이스. Executor 는 thread 풀, 비동기 입출력 및 경량 태스크 체제를 포함한, thread를 닮은 커스텀 하부조직을 정의하기 위한 표준화 된 단순한 인터페이스입니다. 사용중의 구상 Executor 클래스에 응해, 새로운 작성된 thread, 기존의 태스크 실행 thread, 또는 execute()를 호출하는 thread내에서 태스크를 차례차례 또는 동시에 실행할 수 있습니다. ExecutorService 는 보다 완성도의 높은 동기 태스크 실행 체제를 제공합니다. ExecutorService는 태스크의 큐잉 및 스케줄링을 관리해, 제어된 셧다운을 가능하게 합니다. ScheduledExecutorService 서브 인터페이스는 지연 및 주기적인 태스크 실행 지원를 추가합니다. ExecutorServices는 Runnable 와 유사한 결과를 얻을 수 있는 Callable 로 표현되는 임의의 함수의 비동기 실행을 결정하는 메서드를 제공합니다. Future 는 함수의 결과를 돌려주고, 실행이 완료했는지 어떠했는지를 판별 가능하게 해, 실행을 취소하는 수단을 제공합니다. 구현. ThreadPoolExecutor 및 ScheduledThreadPoolExecutor 클래스는 튜닝 가능해 유연성의 높은 thread 풀을 제공합니다. Executors 클래스는 Executor 가장 일반적인 종류 및 구성의 팩토리 메서드 및 이것들에 특히 대응하고 싶은 구두인가의 유틸리티 메서드를 제공합니다. Executor에 근거하는 다른 유틸리티에는 Future 일반적인 확장 가능 구현을 제공하는 구상 클래스 FutureTask 및 비동기 태스크 그룹의 처리 조정을 지원하는 ExecutorCompletionService 가 포함됩니다.

큐

java.util.concurrent ConcurrentLinkedQueue 클래스는 효율 및 확장성이 높고, thread 세이프인 비블로킹 FIFO 큐를 제공합니다. java.util.concurrent 5개의 구현 LinkedBlockingQueue, ArrayBlockingQueue, SynchronousQueue, PriorityBlockingQueue 및 DelayQueue 는 put 및 take 블로킹 버전을 정의하는 확장된 BlockingQueue 인터페이스를 지원 합니다. 프로듀서 컨슈머(consumer), 메세지 처리, 병행 태스크 실행 및 관련된 병행 설계용의 가장 일반적인 사용 컨텍스트은 다른 클래스의 대상이 됩니다.

타이밍

TimeUnit 클래스는 타임 아웃에 근거하는 조작을 지정 및 제어하기 위한 복수의 상세 (나노초를 포함한다)를 제공합니다. 패키지내의 대부분의 클래스에는 무제한의 대기에 더해타임 아웃에 근거하는 조작이 포함됩니다. 타임 아웃을 사용하는 경우는 항상, 메서드가 타임 아웃을 나타내기 전에 대기할 필요가 있는 최소 시간이, 타임 아웃에 의해 지정됩니다. 구현은 타임 아웃의 발생 다음에 올 뿐 빨리 그것을 검출하도록 최선이 노력합니다만, 타임 아웃의 검출로부터 타임 아웃 후에 thread가 실제로 재실행되어까지의 사이에 무제한의 시간이 경과할 가능성이 있습니다.

동기화 장치

일반적으로 사용되는 특수용도의 동기를 지원하기 위해서 4개의 클래스가 사용됩니다 Semaphore is a classic concurrency tool. CountDownLatch is a very simple yet verySemaphore 는 표준적인 concurrent processing 툴입니다.

CountDownLatch 는 매우 단순합니다만, 지정된 수의 신호, 이벤트, 또는 상태에 이를 때까지 블록하기 위한, 일반적인 유틸리티입니다. CyclicBarrier 는 일부의 병행 프로그래밍으로 도움이 되는 설정 가능한 다중 동기 포인트입니다. Exchanger를 사용하면, 2개의 thread가 만났을 때에 객체를 교환할 수 있습니다 . 이것은 몇개의 파이프라인 설계로 유용합니다. (★코멘트 : 이 문장의 전2개의 문장은 번역 대상이라고 생각합니다만, 번역 대상외로서 태그화 되고 있습니다. 번역문을 추가했습니다. 추가 부분：「Semaphore 는 표준적인 concurrent processing 툴입니다. CountDownLatch 는 매우 단순합니다만,」★)

동시 컬렉션

이 패키지는 Queues에 더해multi-thread 컨텍스트에 서의 사용을 목적으로 설계되어 따분한가의 Collection 구현 (ConcurrentHashMap, CopyOnWriteArrayList 및 CopyOnWriteArraySet )을 제공합니다.

이 패키지의 일부의 클래스에서 사용되는 접두사 「Concurrent」는 유사한 「synchronized」클래스 물어 구두인가의 점으로써 차이가 있는 것을 나타냅니다. 예를 들어, java.util.Hashtable 및 Collections.synchronizedMap(new HashMap())는 동기화 됩니다. 다만, ConcurrentHashMap 는 「동시」입니다. 동시 컬렉션은 thread 세이프입니다만, 단일의 배타 락에 의해 제어되지 않습니다. ConcurrentHashMap 특정의 케이스에서는 동시 컬렉션은 임의수의 동시 read 및 조절 가능한 수의 동시 write를 안전하게 허용합니다. 「동기화 되었다」클래스는 단일의 락을 포함한 컬렉션에의 액세스 모든 것을 스케이라비리티를 희생해도 막을 필요가 있는 경우에 유용합니다. 복수의 thread가 공통의 컬렉션에 액세스 하는 것이 예상되는 다른 경우에는 일반적으로 「동시」버전이 우수합니다. 동기화되어 있지 않은 컬렉션은 컬렉션이 공유되어 있지 않은지, 다른 락을 보관 유지하고 있는 경우에게만 액세스 가능한 경우가 뛰어납니다.

대부분의 동시 Collection 구현 (대부분의 Queue를 포함한다)에서는 Iterator에 의해 파스트페이르트라바살은 아니고 「약한 일관성」이 제공되는 점도 java.util 보통 의 규약과는 다릅니다. 약한 일관성을 가지는 반복자는 thread 세이프입니다만, 반드시 반복중에 컬렉션을 다운 당할 필요는 없기 때문에 반복자의 작성 이후의 갱신을 반영하는 일도 반영하지 않는 것도 가능합니다.

도입된 버전 :

1.5