// 等待另一個線程到達(dá)此交換點(diǎn)（除非當(dāng)前線程被中斷），然后將給定的對象傳送給該線程，并接收該線程的對象。
    public V exchange(V x) throws InterruptedException
    //增加超時機(jī)制，超過指定時間，拋TimeoutException異常
    public V exchange(V x, long timeout, TimeUnit unit) throws InterruptedException, TimeoutException

class FillAndEmpty {
    Exchanger<DataBuffer> exchanger = new Exchanger<DataBuffer>();
    DataBuffer initialEmptyBuffer = ... a made-up type
    DataBuffer initialFullBuffer = ...
    
    //填充緩沖區(qū)線程
    class FillingLoop implements Runnable {
        public void run() {
            DataBuffer currentBuffer = initialEmptyBuffer;    //空的緩沖區(qū)
            try {
                while (currentBuffer != null) {
                    addToBuffer(currentBuffer);    //填充數(shù)據(jù)
                    //如果緩沖區(qū)被數(shù)據(jù)填滿，執(zhí)行exchange。等待清空緩沖區(qū)線程也執(zhí)行exchange方法。當(dāng)兩個線程都到達(dá)同步點(diǎn)，交換數(shù)據(jù)。
                    if (currentBuffer.isFull())
                        currentBuffer = exchanger.exchange(currentBuffer);    
                }
            } catch (InterruptedException ex) { ... handle ... }
        }
    }
    
    //清空緩沖區(qū)線程
    class EmptyingLoop implements Runnable {
        public void run() {
            DataBuffer currentBuffer = initialFullBuffer;    //滿的緩沖區(qū)
            try {
                while (currentBuffer != null) {
                    takeFromBuffer(currentBuffer);    //清空緩沖區(qū)
                    //如果緩沖區(qū)被清空，執(zhí)行exchange。等待填充緩沖區(qū)線程也執(zhí)行exchange方法。當(dāng)兩個線程都到達(dá)同步點(diǎn)，交換數(shù)據(jù)。
                    if (currentBuffer.isEmpty())
                        currentBuffer = exchanger.exchange(currentBuffer);
                }
            } catch (InterruptedException ex) { ... handle ...}
        }
    }
 
    void start() {
        new Thread(new FillingLoop()).start();
        new Thread(new EmptyingLoop()).start();
    }
}