> import java.util.Random; > import java.util.concurrent.BlockingQueue; ~~~ public class Consumer implements Runnable { private BlockingQueue<Data> queue; public Consumer(BlockingQueue queu){ this.queue = queu; } //隨機對象 private static Random r = new Random(); @Override public void run() { while(true){ try{ //獲取數據，從頭部獲取如果沒有則等待 Data data = this.queue.take(); //進行數據處理，休眠 0-1000毫秒模擬耗時 Thread.sleep(r.nextInt(1000)); System.out.print("當前消費線程"+Thread.currentThread().getName() +",消費成功，消費id為"+data.getId()); }catch(InterruptedException e){ e.printStackTrace(); } } } } ~~~