Java多线程之~~~线程安全容器的非阻塞容器
2014-10-12 21:45
363 查看
在并发编程中,会经常遇到使用容器。但是如果一个容器不是线程安全的,那么他在多线程的插入或者删除的过程
中就会出现各种问题,就是不同步的问题。所以JDK提供了线程安全的容器,他能保证容器在多线程的情况下安全的插
入和删除。当然,线程安全的容器分为两种,第一种为非阻塞似的,非阻塞的意思是当请求一个容器为空或者这个请求
不能执行的时候,就会报出异常,第二种阻塞的意思是,不能执行的命令不会报出异常,他会等待直到他能执行。下面
我们实现一个例子,这个例子就是多个线程去大量的插入容器数据,而另一个线程去大量的pop出数据。
代码如下
中就会出现各种问题,就是不同步的问题。所以JDK提供了线程安全的容器,他能保证容器在多线程的情况下安全的插
入和删除。当然,线程安全的容器分为两种,第一种为非阻塞似的,非阻塞的意思是当请求一个容器为空或者这个请求
不能执行的时候,就会报出异常,第二种阻塞的意思是,不能执行的命令不会报出异常,他会等待直到他能执行。下面
我们实现一个例子,这个例子就是多个线程去大量的插入容器数据,而另一个线程去大量的pop出数据。
代码如下
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); } } }
package com.bird.concursey.charpet9; import java.util.concurrent.ConcurrentLinkedDeque; public class PollTask implements Runnable { private ConcurrentLinkedDeque<String> list; public PollTask(ConcurrentLinkedDeque<String> list) { super(); this.list = list; } @Override public void run() { for(int i = 0; i < 5000; i++) { list.pollFirst(); list.pollLast(); } } public static void main(String[] args) { ConcurrentLinkedDeque<String> list = new ConcurrentLinkedDeque<String>(); Thread threads[] = new Thread[100]; for(int i = 0; i < 100; i++) { AddTask task = new AddTask(list); threads[i] = new Thread(task); threads[i].start(); } System.out.printf("Main: %d AddTask threads have been launched\n",threads.length); for(int i = 0; i < threads.length; i++) { try { threads[i].join(); } catch (InterruptedException e) { e.printStackTrace(); } } System.out.printf("Main: Size of the List: %d\n",list.size()); for (int i=0; i< threads.length; i++){ PollTask task = new PollTask(list); threads[i] = new Thread(task); threads[i].start(); } System.out.printf("Main: %d PollTask threads have been launched\n",threads.length); for(int i = 0; i < threads.length; i++) { try { threads[i].join(); } catch (InterruptedException e) { e.printStackTrace(); } } System.out.printf("Main: Size of the List: %d\n",list.size()); } }
相关文章推荐
- java多线程 --ConcurrentLinkedQueue 非阻塞 线程安全队列
- C#转Java之路之三:多线程并发容器即线程安全的容器
- Java多线程之~~~线程安全容器的非堵塞容器
- Java 7之多线程并发容器 - LinkedBlockingQueue
- java多线程基础知识:如何编写线程安全代码
- Java多线程 阻塞队列和并发集合
- Java容器的线程安全
- (13)多线程与并发库之java5阻塞队列(BlockingQueue)的应用----子线程循环10次,接着主线程循环100次,接着又回到子线程循环10次,接着再回到主线程循环100次,如此循环50次
- Java 7之多线程并发容器 - ConcurrentHashMap
- Java ,单实例 多线程 ,web容器,servlet与struts1-2.x系列,线程安全的解决
- Java ,单实例 多线程 ,web容器,servlet与struts1-2.x系列,线程安全的解决方案
- sqlite4java中的多线程队列使用(线程安全)
- Java多线程 阻塞队列和并发集合
- Java多线程 阻塞队列和并发集合
- Java多线程 阻塞队列和并发集合
- Java多线程与并发库高级应用之阻塞队列BlockingQueue
- thrift java多线程非阻塞同步/异步调用实例
- 【JAVA-CONCURRENT】 利用SEMAPHORE 实现有界阻塞容器
- Java多线程——4 阻塞队列
- Java的容器的线程安全