Java多线程之~~~线程安全容器的非阻塞容器



Java多线程之~~~线程安全容器的非阻塞容器

在并发编程中，会经常遇到使用容器。但是如果一个容器不是线程安全的，那么他在多线程的插入或者删除的过程

 

中就会出现各种问题，就是不同步的问题。所以JDK提供了线程安全的容器，他能保证容器在多线程的情况下安全的插

 

入和删除。当然，线程安全的容器分为两种，第一种为非阻塞似的，非阻塞的意思是当请求一个容器为空或者这个请求

 

不能执行的时候，就会报出异常，第二种阻塞的意思是，不能执行的命令不会报出异常，他会等待直到他能执行。下面

 

我们实现一个例子，这个例子就是多个线程去大量的插入容器数据，而另一个线程去大量的pop出数据。

 

 


 

代码如下

 

  1. package com.bird.concursey.charpet9;
  3. import java.util.concurrent.ConcurrentLinkedDeque;
  5. public class AddTask implements Runnable {
  7.     private ConcurrentLinkedDeque<String> list;
  9.     public AddTask(ConcurrentLinkedDeque<String> list) {
  10.         super();
  11.         this.list = list;
  12.     }
  14.     @Override
  15.     public void run() {
  16.         String name = Thread.currentThread().getName();
  17.         for(int i = 0; i < 1000; i++) {
  18.             list.add(name + i);
  19.         }
  20.     }
  22. }

 

package com.bird.concursey.charpet9;

import java.util.concurrent.ConcurrentLinkedDeque;

public class AddTask implements Runnable {

	private ConcurrentLinkedDeque<String> list;

	public AddTask(ConcurrentLinkedDeque<String> list) {
		super();
		this.list = list;
	}

	@Override
	public void run() {
		String name = Thread.currentThread().getName();
		for(int i = 0; i < 1000; i++) {
			list.add(name + i);
		}
	}

}

 

 

 

 

 

  1. package com.bird.concursey.charpet9;
  3. import java.util.concurrent.ConcurrentLinkedDeque;
  5. public class PollTask implements Runnable {
  7.     private ConcurrentLinkedDeque<String> list;
  9.     public PollTask(ConcurrentLinkedDeque<String> list) {
  10.         super();
  11.         this.list = list;
  12.     }
  14.     @Override
  15.     public void run() {
  16.         for(int i = 0; i < 5000; i++) {
  17.             list.pollFirst();
  18.             list.pollLast();
  19.         }
  20.     }
  22.     public static void main(String[] args) {
  23.         ConcurrentLinkedDeque<String> list = new ConcurrentLinkedDeque<String>();
  24.         Thread threads[] = new Thread[100];
  25.         for(int i = 0; i < 100; i++) {
  26.             AddTask task = new AddTask(list);
  27.             threads[i] = new Thread(task);
  28.             threads[i].start();
  29.         }
  30.         System.out.printf(“Main: %d AddTask threads have been launched\n”,threads.length);
  31.         for(int i = 0; i < threads.length; i++) {
  32.             try {
  33.                 threads[i].join();
  34.             } catch (InterruptedException e) {
  35.                 e.printStackTrace();
  36.             }
  37.         }
  38.         System.out.printf(“Main: Size of the List: %d\n”,list.size());
  39.         for (int i=0; i< threads.length; i++){
  40.             PollTask task = new PollTask(list);
  41.             threads[i] = new Thread(task);
  42.             threads[i].start();
  43.         }
  44.         System.out.printf(“Main: %d PollTask threads have been launched\n”,threads.length);
  45.         for(int i = 0; i < threads.length; i++) {
  46.             try {
  47.                 threads[i].join();
  48.             } catch (InterruptedException e) {
  49.                 e.printStackTrace();
  50.             }
  51.         }
  52.         System.out.printf(“Main: Size of the List: %d\n”,list.size());
  53.     }
  54. }