通过实例了解java TransferQueue

public class LinkedTransferQueueDemo {static LinkedTransferQueue<String> lnkTransQueue = new LinkedTransferQueue<String>();public static void main(String[] args) {ExecutorService exService = Executors.newFixedThreadPool(2);Producer producer = new LinkedTransferQueueDemo().new Producer();Consumer consumer = new LinkedTransferQueueDemo().new Consumer();exService.execute(producer);exService.execute(consumer);exService.shutdown();}class Producer implements Runnable{@Overridepublic void run() {for(int i=0;i<3;i++){try {System.out.println("Producer is waiting to transfer...");lnkTransQueue.transfer("A"+i);System.out.println("producer transfered element: A"+i);} catch (InterruptedException e) {e.printStackTrace();}}}}class Consumer implements Runnable{@Overridepublic void run() {for(int i=0;i<3;i++){try {System.out.println("Consumer is waiting to take element...");String s= lnkTransQueue.take();System.out.println("Consumer received Element: "+s);} catch (InterruptedException e) {e.printStackTrace();}}}}}

Producer is waiting to transfer...Consumer is waiting to take element...producer transfered element: A0Producer is waiting to transfer...Consumer received Element: A0Consumer is waiting to take element...producer transfered element: A1Producer is waiting to transfer...Consumer received Element: A1Consumer is waiting to take element...Consumer received Element: A2producer transfered element: A2