Lines Matching defs:exchange
44 * {@link #exchange exchange} method, matches with a partner thread,
68 * currentBuffer = exchanger.exchange(currentBuffer);
81 * currentBuffer = exchanger.exchange(currentBuffer);
95 * successfully exchange objects via an {@code Exchanger}, actions
96 * prior to the {@code exchange()} in each thread
98 * those subsequent to a return from the corresponding {@code exchange()}
113 * for another to invoke exchange. That second "fulfilling" thread
127 * threads performing an exchange. Incoming threads pick slots
173 * entangled with indexing and hashing inside the exchange code,
327 * Main exchange function, handling the different policy variants.
332 * @param item the (non-null) item to exchange
456 * in public exchange method to abort if interrupted on entry.
587 * Waits for another thread to arrive at this exchange point (unless
592 * <p>If another thread is already waiting at the exchange point then
595 * receiving the object passed to the exchange by that other thread.
597 * <p>If no other thread is already waiting at the exchange then the
601 * <li>Some other thread enters the exchange; or
609 * for the exchange,
614 * @param x the object to exchange
619 public V exchange(V x) throws InterruptedException {
632 * Waits for another thread to arrive at this exchange point (unless
637 * <p>If another thread is already waiting at the exchange point then
640 * receiving the object passed to the exchange by that other thread.
642 * <p>If no other thread is already waiting at the exchange then the
646 * <li>Some other thread enters the exchange; or
655 * for the exchange,
664 * @param x the object to exchange
671 * before another thread enters the exchange
673 public V exchange(V x, long timeout, TimeUnit unit)