ViewVC Help

View File | Revision Log | Show Annotations | Download File | Root Listing

root/jsr166/jsr166/src/jsr166y/TransferQueue.java

Comparing jsr166/src/jsr166y/TransferQueue.java (file contents):
Revision 1.8 by jsr166, Fri Jul 31 07:30:29 2009 UTC vs.
Revision 1.9 by jsr166, Sat Aug 1 20:26:50 2009 UTC

#	Line 39 | Line 39 | import java.util.concurrent.*;
39		*/
40		public interface TransferQueue<E> extends BlockingQueue<E> {
41		/**
42	<	* Transfers the specified element immediately if there exists a
43	<	* consumer already waiting to receive it (in {@link #take} or
44	<	* timed {@link #poll(long,TimeUnit) poll}), otherwise returning
45	<	* {@code false} without enqueuing the element.
42	>	* Transfers the element to a waiting consumer immediately, if possible.
43	>	*
44	>	* <p>More precisely, transfers the specified element immediately
45	>	* if there exists a consumer already waiting to receive it (in
46	>	* {@link #take} or timed {@link #poll(long,TimeUnit) poll}),
47	>	* otherwise returning {@code false} without enqueuing the element.
48		*
49		* @param e the element to transfer
50		* @return {@code true} if the element was transferred, else
#	Line 56 | Line 58 | public interface TransferQueue<E> extend
58		boolean tryTransfer(E e);
59
60		/**
61	<	* Inserts the specified element into this queue, waiting if
62	<	* necessary for space to become available and the element to be
63	<	* received by a consumer invoking {@code take} or {@code poll}.
61	>	* Transfers the element to a consumer, waiting if necessary to do so.
62	>	*
63	>	* <p>More precisely, transfers the specified element immediately
64	>	* if there exists a consumer already waiting to receive it (in
65	>	* {@link #take} or timed {@link #poll(long,TimeUnit) poll}),
66	>	* else waits until the element is received by a consumer.
67		*
68		* @param e the element to transfer
69		* @throws InterruptedException if interrupted while waiting,
70	<	*         in which case the element is not enqueued
70	>	*         in which case the element is not left enqueued
71		* @throws ClassCastException if the class of the specified element
72		*         prevents it from being added to this queue
73		* @throws NullPointerException if the specified element is null
#	Line 72 | Line 77 | public interface TransferQueue<E> extend
77		void transfer(E e) throws InterruptedException;
78
79		/**
80	<	* Inserts the specified element into this queue, waiting up to
81	<	* the specified wait time if necessary for space to become
82	<	* available and the element to be received by a consumer invoking
83	<	* {@code take} or {@code poll}.
80	>	* Transfers the element to a consumer if it is possible to do so
81	>	* before the timeout elapses.
82	>	*
83	>	* <p>More precisely, transfers the specified element immediately
84	>	* if there exists a consumer already waiting to receive it (in
85	>	* {@link #take} or timed {@link #poll(long,TimeUnit) poll}),
86	>	* else waits until the element is received by a consumer,
87	>	* returning {@code false} if the specified wait time elapses
88	>	* before the element can be transferred.
89		*
90		* @param e the element to transfer
91		* @param timeout how long to wait before giving up, in units of
#	Line 84 | Line 94 | public interface TransferQueue<E> extend
94		*        {@code timeout} parameter
95		* @return {@code true} if successful, or {@code false} if
96		*         the specified waiting time elapses before completion,
97	<	*         in which case the element is not enqueued
97	>	*         in which case the element is not left enqueued
98		* @throws InterruptedException if interrupted while waiting,
99	<	*         in which case the element is not enqueued
99	>	*         in which case the element is not left enqueued
100		* @throws ClassCastException if the class of the specified element
101		*         prevents it from being added to this queue
102		* @throws NullPointerException if the specified element is null

Diff Legend

–	Removed lines
+	Added lines
<	Changed lines
>	Changed lines