Java ConcurrentLinkedQueue队列线程安全操作详解编程语言

import java.util.Queue;  import java.util.concurrent.ConcurrentLinkedQueue;    /**   *   * 线程安全队列Queue实现计算科学古老的线程同步问题：生产者-消费者模型   *   * @author phil   *   */  public class Demo {  public static void main(String[] args) {  // 线程操作安全队列，装载数据  Queue String  queue = new ConcurrentLinkedQueue String     // 消费者线程：不断的消费队列中的数据  // 该线程不停的从队列中取出队列中最头部的数据  new Thread(new Runnable() {  @Override  public void run() {  while (true) {  // 从队列的头部取出并删除该条数据  String s = queue.poll();    if (s != null) {  System.out.println(System.currentTimeMillis() +  取出数据:  + s);  }  }  }    }).start();    // 生产者线程A：不断的生产单个数据并装入队列中  // 该线程模拟不停的在队列中装入一个数据  new Thread(new Runnable() {  private int count = 0;  private int number = 0;    @Override  public void run() {  while (true) {  number = count++;  System.out.println( 装载数据：  + number);  queue.add(String.valueOf(number));    try {  Thread.sleep(1000);  } catch (InterruptedException e) {  e.printStackTrace();  }  }  }    }).start();    // 生产者线程B：不断的生产批量数据并装入队列中  // 该线程模拟不停的在队列中装入一批数据  new Thread(new Runnable() {  private List String  lists = new ArrayList String   private int count = 0;    @Override  public void run() {  while (true) {  // 一批数据的数量，不定长  count = (int) (Math.random() * 5);  for (int i = 0; i   count; i++) {  lists.add( 批量数据-  + i +  ,  + Math.random());  }    queue.addAll(lists);  lists.clear();    try {  Thread.sleep(1000);  } catch (InterruptedException e) {  e.printStackTrace();  }  }  }    }).start();  }  }

代码运行结果：

装载数据：0 

1490417519703取出数据:0 

1490417519705取出数据:批量数据-0,0.9045746291285363 

装载数据：1 

1490417520703取出数据:1 

1490417520705取出数据:批量数据-0,0.9378737341890285 

1490417520705取出数据:批量数据-1,0.5609780480099475 

1490417520705取出数据:批量数据-2,0.27383078038481046 

1490417520705取出数据:批量数据-3,0.6824300990854635 

装载数据：2 

1490417521704取出数据:2 

1490417521706取出数据:批量数据-0,0.23916865770830298 

装载数据：3 

1490417522704取出数据:3 

1490417522706取出数据:批量数据-0,0.4169859285695523 

1490417522706取出数据:批量数据-1,0.6667611178989155 

1490417522706取出数据:批量数据-2,0.9026516620769446 

1490417522706取出数据:批量数据-3,0.3491566771349188 

装载数据：4 

1490417523705取出数据:4 

1490417523707取出数据:批量数据-0,0.5634243124726268 

1490417523707取出数据:批量数据-1,0.4021826644433847 

装载数据：5 

1490417524705取出数据:5 

1490417524707取出数据:批量数据-0,0.9431588628811881 

1490417524707取出数据:批量数据-1,0.8762171226841987 

1490417524707取出数据:批量数据-2,0.0470837112538508 

装载数据：6 

1490417525705取出数据:6 

1490417525707取出数据:批量数据-0,0.31099249499423265 

1490417525707取出数据:批量数据-1,0.7660770869693369 

1490417525707取出数据:批量数据-2,0.3209338524956993 

1490417525707取出数据:批量数据-3,0.2525376039263991 

装载数据：7 

1490417526706取出数据:7 

1490417526708取出数据:批量数据-0,0.6369286896471094

致谢：
冯贵兵对本文有重大贡献！

附录：
1，《Java同步机制：synchronized，wait，notify》链接地址：http://blog.csdn.net/zhangphil/article/details/43800949
2，《Java线程同步：生产者-消费者 模型（代码示例）》链接地址：http://blog.csdn.net/zhangphil/article/details/43800967

原创文章，作者：ItWorker，如若转载，请注明出处：https://blog.ytso.com/7571.html

cjava