java.util.concurrent
클래스 SynchronousQueue<E>

java.lang.Object 
  java.util.AbstractCollection <E>
      java.util.AbstractQueue <E>
          java.util.concurrent.SynchronousQueue<E>

형태 파라미터:

E - 컬렉션내에 존재하는 요소의 형태

모든 구현된 인터페이스:

Serializable, Iterable <E>, Collection <E>, BlockingQueue <E>, Queue <E>

public class SynchronousQueue<E>
extends AbstractQueue <E>
implements BlockingQueue <E>, Serializable 

각 put가 take를 대기해, 그 역도 실행할 필요가 있는블록 큐 . 동기 큐는 내부 용량을 일절 가지지 않습니다. 요소는 취득을 시도해도 존재할 뿐이기 때문에 동기 큐로 peek를 실행할 수 없습니다. 다른 thread가 삭제를 시도하지 않은 한, 어느 메서드를 사용해도 요소를 추가할 수 없습니다. 반복하는 것이 존재하지 않기 때문에 반복은 실행할 수 없습니다. 큐의 「선두」는 최초로 큐에 넣어진 thread가 큐에 추가를 시도하는 요소입니다. 큐에 넣어진 thread가 존재하지 않는 경우, 추가되는 요소는 존재하지 않고, 선두는 null가 됩니다. 다른 Collection 메서드 (예를 들어 contains)를 위해서 SynchronousQueue는 비어있는 컬렉션으로서 동작합니다. 이 큐는 null 요소를 허가하지 않습니다.

동기 큐는 CSP 나 Ada 로 사용되는 런 뚱뚱이 채널을 닮아 있습니다. 이것들은 정보나 이벤트, 태스크를 건네주기 위해서 어느 thread로 실행중의 객체를 다른 thread로 실행중의 객체와 동기 시킬 필요가 있는 핸드 오프 설계에 몹시 적합합니다.

이 클래스는 대기중의 프로듀서 및 컨슈머(consumer) thread의 순서부를 결정하는 옵션의 균등성 정책를 지원 합니다. 디폴트에서는 이 순서부는 보증되지 않습니다. 다만, true로 설정된 균등성 정책를 사용해 구축된 큐에서는 thread가 FIFO 순서로 액세스 하는 것이 허가됩니다. 일반적으로 균등성에 의해 throughput가 저하합니다만, 변동성도 저하하기 때문에 throughput가 극단적으로 적게 될 것은 없습니다.

이 클래스와 그 반복자는 Collection 및 Iterator 인터페이스의 옵션의 메서드를 모두 구현합니다.

이 클래스는 Java Collections Framework 멤버입니다.

도입된 버전 :

1.5

관련 항목:

직렬화 된 형식

생성자 개요

SynchronousQueue ()
불균등 액세스 정책를 사용해, SynchronousQueue를 작성합니다.

SynchronousQueue (boolean fair)
지정된 균등성 정책를 사용해, SynchronousQueue를 작성합니다.

메서드 개요

void	clear () 아무것도 실시하지 않습니다.
boolean	contains (Object o) 항상 false를 리턴합니다.
boolean	containsAll (Collection <? > c) 지정된 컬렉션이 비어있지 않은 경우, false를 리턴합니다.
int	drainTo (Collection <? super E > c) 이용 가능한 모든 요소를 이 큐로부터 삭제해, 지정된 컬렉션에 추가합니다.
int	drainTo (Collection <? super E > c, int maxElements) 지정된 수이내의 이용 가능한 요소를 이 큐로부터 삭제해, 지정된 컬렉션에 추가합니다.
boolean	isEmpty () 항상 true를 리턴합니다.
Iterator <E >	iterator () hasNext가 항상 false를 돌려주는 비어있는 반복자를 리턴합니다.
boolean	offer (E o) 다른 thread가 지정된 요소의 수취를 대기하고 있는 경우, 이 큐에 그것을 삽입합니다.
boolean	offer (E o, long timeout, TimeUnit unit) 지정된 요소를 이 큐에 삽입합니다.
E	peek () 항상 null을 리턴합니다.
E	poll () 현재, 다른 thread가 요소를 이용 가능하게 하고 있는 경우, 이 큐의 선두를 취득해 삭제합니다.
E	poll (long timeout, TimeUnit unit) 큐의 선두를 취득해 삭제합니다.
void	put (E o) 지정된 요소를 이 큐에 추가합니다.
int	remainingCapacity () 항상 제로를 리턴합니다.
boolean	remove (Object o) 항상 false를 리턴합니다.
boolean	removeAll (Collection <? > c) 항상 false를 리턴합니다.
boolean	retainAll (Collection <? > c) 항상 false를 리턴합니다.
int	size () 항상 제로를 리턴합니다.
E	take () 이 큐의 선두를 취득해 삭제합니다.
Object []	toArray () 길이 제로의 배열을 리턴합니다.
<T> T[]	toArray (T[] a) 지정된 배열의 제로 번째의 요소를 null로 설정해 (배열이 제로가 아닌 길이를 보관 유지하는 경우), 그것을 리턴합니다.

클래스 java.util. AbstractQueue 로부터 상속된 메서드

add, addAll, element, remove

클래스 java.util. AbstractCollection 로부터 상속된 메서드

toString

클래스 java.lang. Object 로부터 상속된 메서드

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

인터페이스 java.util.concurrent. BlockingQueue 로부터 상속된 메서드

add

인터페이스 java.util. Queue 로부터 상속된 메서드

element, remove

인터페이스 java.util. Collection 로부터 상속된 메서드

addAll, equals, hashCode

생성자 상세

SynchronousQueue

public SynchronousQueue()

불균등 액세스 정책를 사용해, SynchronousQueue를 작성합니다.

SynchronousQueue

public SynchronousQueue(boolean fair)

지정된 균등성 정책를 사용해, SynchronousQueue를 작성합니다.

파라미터:

fair - true인 경우, thread는 액세스의 FIFO 순서로 경합 한다. 그렇지 않은 경우, 순서는 지정되지 않는다

메서드의 상세

put

public void put(E  o)
         throws InterruptedException 

지정된 요소를 이 큐에 추가합니다. 필요하게 응해 다른 thread가 그것을 받을 때까지 대기합니다.

정의:

인터페이스 BlockingQueue <E > 내의 put

파라미터:

o - 추가하는 요소

예외:

InterruptedException - 대기중에 인터럽트가 발생했을 경우

NullPointerException - 지정된 요소가 null 인 경우

offer

public boolean offer(E  o,
                     long timeout,
                     TimeUnit  unit)
              throws InterruptedException 

지정된 요소를 이 큐에 삽입합니다. 필요하게 응해 다른 thread가 그것을 받는 것을 지정된 대기 시간까지 대기합니다.

정의:

인터페이스 BlockingQueue <E > 내의 offer

파라미터:

o - 추가하는 요소

timeout - 처리를 중지할 때까지의 대기 시간. 단위는 unit

unit - timeout 파라미터의 해석 방법을 지정하는 TimeUnit

반환값:

성공했을 경우는 true, 컨슈머(consumer)가 나타나기 전으로 지정된 대기 시간이 경과했을 경우는 false

예외:

InterruptedException - 대기중에 인터럽트가 발생했을 경우

NullPointerException - 지정된 요소가 null 인 경우

take

public E  take()
       throws InterruptedException 

이 큐의 선두를 취득해 삭제합니다. 필요하게 응해 다른 thread가 그것을 삽입하는 것을 대기합니다.

정의:

인터페이스 BlockingQueue <E > 내의 take

반환값:

큐의 선두

예외:

InterruptedException - 대기중에 인터럽트가 발생했을 경우

poll

public E  poll(long timeout,
              TimeUnit  unit)
       throws InterruptedException 

큐의 선두를 취득해 삭제합니다. 필요하게 응해 다른 thread가 그것을 삽입하는 것을 지정된 대기 시간까지 대기합니다.

정의:

인터페이스 BlockingQueue <E > 내의 poll

파라미터:

timeout - 처리를 중지할 때까지의 대기 시간. 단위는 unit

unit - timeout 파라미터의 해석 방법을 지정하는 TimeUnit

반환값:

이 큐의 선두. 지정된 대기 시간이 경과해도 요소가 존재하지 않는 경우는 null

예외:

InterruptedException - 대기중에 인터럽트가 발생했을 경우

offer

public boolean offer(E  o)

다른 thread가 지정된 요소의 수취를 대기하고 있는 경우, 이 큐에 그것을 삽입합니다.

정의:

인터페이스 BlockingQueue <E > 내의 offer

정의:

인터페이스 Queue <E > 내의 offer

파라미터:

o - 추가하는 요소

반환값:

요소를 이 큐에 추가 가능한 경우는 true, 그렇지 않은 경우는 false

예외:

NullPointerException - 지정된 요소가 null 인 경우

poll

public E  poll()

현재, 다른 thread가 요소를 이용 가능하게 하고 있는 경우, 이 큐의 선두를 취득해 삭제합니다.

정의:

인터페이스 Queue <E > 내의 poll

반환값:

큐의 선두. 이용 가능한 요소가 존재하지 않는 경우는 null

isEmpty

public boolean isEmpty()

항상 true를 리턴합니다. SynchronousQueue는 내부 용량을 보관 유지하지 않습니다.

정의:

인터페이스 Collection <E > 내의 isEmpty

오버라이드(override):

클래스 AbstractCollection <E > 내의 isEmpty

반환값:

true

size

public int size()

항상 제로를 리턴합니다. SynchronousQueue는 내부 용량을 보관 유지하지 않습니다.

정의:

인터페이스 Collection <E > 내의 size

정의:

클래스 AbstractCollection <E > 내의 size

반환값:

제로

remainingCapacity

public int remainingCapacity()

항상 제로를 리턴합니다. SynchronousQueue는 내부 용량을 보관 유지하지 않습니다.

정의:

인터페이스 BlockingQueue <E > 내의 remainingCapacity

반환값:

제로

clear

public void clear()

아무것도 실시하지 않습니다. SynchronousQueue는 내부 용량을 보관 유지하지 않습니다.

정의:

인터페이스 Collection <E > 내의 clear

오버라이드(override):

클래스 AbstractQueue <E > 내의 clear

contains

public boolean contains(Object  o)

항상 false를 리턴합니다. SynchronousQueue는 내부 용량을 보관 유지하지 않습니다.

정의:

인터페이스 Collection <E > 내의 contains

오버라이드(override):

클래스 AbstractCollection <E > 내의 contains

파라미터:

o - 요소

반환값:

false

remove

public boolean remove(Object  o)

항상 false를 리턴합니다. SynchronousQueue는 내부 용량을 보관 유지하지 않습니다.

정의:

인터페이스 Collection <E > 내의 remove

오버라이드(override):

클래스 AbstractCollection <E > 내의 remove

파라미터:

o - 삭제하는 요소

반환값:

false

containsAll

public boolean containsAll(Collection <? > c)

지정된 컬렉션이 비어있지 않은 경우, false를 리턴합니다. SynchronousQueue는 내부 용량을 보관 유지하지 않습니다.

정의:

인터페이스 Collection <E > 내의 containsAll

오버라이드(override):

클래스 AbstractCollection <E > 내의 containsAll

파라미터:

c - 컬렉션

반환값:

지정된 컬렉션이 비어있지 않은 경우는 false

관련 항목:

AbstractCollection.contains(Object)

removeAll

public boolean removeAll(Collection <? > c)

항상 false를 리턴합니다. SynchronousQueue는 내부 용량을 보관 유지하지 않습니다.

정의:

인터페이스 Collection <E > 내의 removeAll

오버라이드(override):

클래스 AbstractCollection <E > 내의 removeAll

파라미터:

c - 컬렉션

반환값:

false

관련 항목:

AbstractCollection.remove(Object), AbstractCollection.contains(Object)

retainAll

public boolean retainAll(Collection <? > c)

항상 false를 리턴합니다. SynchronousQueue는 내부 용량을 보관 유지하지 않습니다.

정의:

인터페이스 Collection <E > 내의 retainAll

오버라이드(override):

클래스 AbstractCollection <E > 내의 retainAll

파라미터:

c - 컬렉션

반환값:

false

관련 항목:

AbstractCollection.remove(Object), AbstractCollection.contains(Object)

peek

public E  peek()

항상 null을 리턴합니다. 요소가 활성화 대기되어 있지 않은 경우, SynchronousQueue는 요소를 돌려주지 않습니다.

정의:

인터페이스 Queue <E > 내의 peek

반환값:

null

iterator

public Iterator <E > iterator()

hasNext가 항상 false를 돌려주는 비어있는 반복자를 리턴합니다.

정의:

인터페이스 Iterable <E > 내의 iterator

정의:

인터페이스 Collection <E > 내의 iterator

정의:

클래스 AbstractCollection <E > 내의 iterator

반환값:

비어있는 반복자

toArray

public Object [] toArray()

길이 제로의 배열을 리턴합니다.

정의:

인터페이스 Collection <E > 내의 toArray

오버라이드(override):

클래스 AbstractCollection <E > 내의 toArray

반환값:

길이 제로의 배열

toArray

public <T> T[] toArray(T[] a)

지정된 배열의 제로 번째의 요소를 null로 설정해 (배열이 제로가 아닌 길이를 보관 유지하는 경우), 그것을 리턴합니다.

정의:

인터페이스 Collection <E > 내의 toArray

오버라이드(override):

클래스 AbstractCollection <E > 내의 toArray

파라미터:

a - 배열

반환값:

지정된 배열

drainTo

public int drainTo(Collection <?  super E > c)

인터페이스 BlockingQueue 기술:

이용 가능한 모든 요소를 이 큐로부터 삭제해, 지정된 컬렉션에 추가합니다. 이 조작은 이 큐를 반복해 폴링 하는 경우보다 효율적인 경우가 있습니다. 컬렉션 c에 요소의 add 조작을 시도할 때에 장해가 발생했을 경우, 관련된 예외의 Throw시에 요소가 컬렉션의 어느 것에도 존재하지 않는지, 한편 또는 양쪽 모두에 존재할 가능성이 있습니다. 큐를 자기 자신에게 배출하는 것을 시도하면, IllegalArgumentException이 발생 됩니다. 또, 이 조작의 진행중으로 지정된 컬렉션이 변경되었을 경우의 동작은 정의되지 않습니다.

정의:

인터페이스 BlockingQueue <E > 내의 drainTo

파라미터:

c - 요소의 전송처의 컬렉션

반환값:

전송 되는 요소의 수

drainTo

public int drainTo(Collection <?  super E > c,
                   int maxElements)

인터페이스 BlockingQueue 기술:

지정된 수이내의 이용 가능한 요소를 이 큐로부터 삭제해, 지정된 컬렉션에 추가합니다. 컬렉션 c에 요소의 add 조작을 시도할 때에 장해가 발생했을 경우, 관련된 예외의 Throw시에 요소가 컬렉션의 어느 것에도 존재하지 않는지, 한편 또는 양쪽 모두에 존재할 가능성이 있습니다. 큐를 자기 자신에게 배출하는 것을 시도하면, IllegalArgumentException이 발생 됩니다. 또, 이 조작의 진행중으로 지정된 컬렉션이 변경되었을 경우의 동작은 정의되지 않습니다.

정의:

인터페이스 BlockingQueue <E > 내의 drainTo

파라미터:

c - 요소의 전송처의 컬렉션

maxElements - 전송 하는 요소의 최대수

반환값:

전송 되는 요소의 수