~~~ public class Provider implements{ //共享緩沖區 private BlockingQueue<Data> queue; //多線程間是否啟動的變量，有強制從主存中刷新的功能，即使返回線程狀態 private volatile boolean isRunning =true; //id生成器 private static AtomicInteger count =new AtomicInteger(); //隨機對象 private static Random r=new Random(); public Provider(BlockingQueue<Data> queue){ this.queue=queue; } public void run(){ while(isRunning){ //隨機休眠0-1000ms,表示數據獲取 try{ Thread.sleep(r.nextInt(1000)); int id=count.incrementAndGet(); Data data=new Data(Integer.toString(id),"數據"+id); System.out.println("當前線程:"+ Thread.currentThread().getName() + ",獲取了數據，id為:"+ id+ ",進行裝載到公共緩沖區中。。。")； if(!this.queue.offer(data,2,TimeUnit.SECONDS)){ System.out.print("提交緩沖區數據失敗"); } } catch (InterruptedException e) { e.printStackTrace(); } System.out.print("aaa"); } } //用控制變量進行終止 public void stop(){ this.isRunning = false; } ~~~