以下有两种方式实现,第一种,使用传统的链表实现。
//ZRZn类,是一个数据类型,有一个public的id属性 public class ZRZn { public int id; } //生产者,向队列里添加数据 public class Producer extends Thread{ private LinkedList<ZRZn> buffer; public Producer(LinkedList<ZRZn> buffer){ this.buffer = buffer; } public void run(){ int id = 0; while(true){ synchronized (buffer) { if(buffer.size() == 0){ id++; ZRZn temp = new ZRZn(); temp.id = id; buffer.add(temp); System.out.println("向队列中加入了一个ZRZn对象,id是 "+temp.id); buffer.notify(); }else{ try { buffer.wait(); Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } } } } } } //消费者,从队列里面拿出数据 public class Customer extends Thread{ private LinkedList<ZRZn> buffer; public Customer(LinkedList<ZRZn> buffer){ this.buffer = buffer; } public void run(){ while(true){ synchronized (buffer) { if(buffer.size() > 0){ ZRZn temp = buffer.remove(0); System.out.println("从队列中拿出了一个ZRZn对象,id是 "+temp.id); buffer.notify(); }else{ try { buffer.wait(); Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } } } } } } //主函数类,测试 public class Manage { public static void main(String[] args) { //数据缓冲链表 java.util.LinkedList<ZRZn> buffer= new java.util.LinkedList<ZRZn>(); Producer pr = new Producer(buffer); Customer cr = new Customer(buffer); pr.start(); cr.start(); } }
以上方法使用常规的LinkedList链表,并运用了链表的notify()和wait()方法,用来执行存放和取出数据。
下一种是运用java.util.concurrent类里面的LinkedBlockingQueue队列,这种队列的优势是它里面自带的take()和put()方法在没有取得或者放入数据时会阻塞,这样就确保一定会一次性取出和放入数据。以下是代码,每个类的作用与上一种方法相同。
public class Customer extends Thread{ private LinkedBlockingQueue<ZRZn> buffer; public Customer(LinkedBlockingQueue<ZRZn> buffer){ this.buffer = buffer; } public void run(){ int id = 0; while(true){ id++; ZRZn temp = new ZRZn(); temp.id = id; try { buffer.put(temp); System.out.println("向队列中加入了一个ZRZn对象,id是 "+temp.id); Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } } } } public class Producer extends Thread{ private LinkedBlockingQueue<ZRZn> buffer; public Producer(LinkedBlockingQueue<ZRZn> buffer){ this.buffer = buffer; } public void run(){ while(true){ try { ZRZn temp = buffer.take(); System.out.println("从队列中拿出了一个ZRZn对象,id是 "+temp.id); } catch (InterruptedException e) { e.printStackTrace(); } } } } public class Manage { public static void main(String[] args) { //数据缓冲链表 java.util.concurrent.LinkedBlockingQueue<ZRZn> buffer = new LinkedBlockingQueue<ZRZn>(1); Producer pr = new Producer(buffer); Customer cr = new Customer(buffer); pr.start(); cr.start(); } }