多线程(并发)学习笔记
2012-06-26 16:06
141 查看
1,无论以哪种方式启动一个线程,要给线程一个名字,对排错、监控有帮助。
2,要对线程interrupt做处理。
3,Futrure 是任务的提交者和执行者之间的通讯手段,get()会阻塞;
4,阻塞队列,常用的数据结构,用于生产者消费者模式,常用三种阻塞队列为ArrayBlockingQueue,LinkedBlockingQueue,SynchronousQueue,
使用阻塞队列时不要使用从Queue继承下来的方法,否则失去Blocking特性。
在BlockingQueue中那个,使用put和take,而非offer和poll。
下面是用lock实现blockingq的pv操作
5,ReentrantLock和Synchronized的关系
Synchronized是lock的一种简化实现,一个lock可以对应多个Condition,而Syschronized把lock和Condition合并了,可以说Syschronized是Lock简易版本,而且效率没有lock高。
6,代替锁得办法,硬件原子操作,lockfree算法。lockfree算法分三个步骤,循环,CAS(compare and set),返回。
7,concurrentHashMap数据结构使用了lockfree的算法,支持多个writer并发。
未完待续。。。。
2,要对线程interrupt做处理。
3,Futrure 是任务的提交者和执行者之间的通讯手段,get()会阻塞;
ExecutorService executor = Executors.newSingleThreadExecutor(); Callable<Object> task = new Callable<Object>() { @Override public Object call() throws Exception { Object result= "..."; return result; } }; Future<Object> future =executor.submit(task); future.get();
4,阻塞队列,常用的数据结构,用于生产者消费者模式,常用三种阻塞队列为ArrayBlockingQueue,LinkedBlockingQueue,SynchronousQueue,
使用阻塞队列时不要使用从Queue继承下来的方法,否则失去Blocking特性。
在BlockingQueue中那个,使用put和take,而非offer和poll。
下面是用lock实现blockingq的pv操作
public class BlockingQ { private Lock lock = new ReentrantLock(); private Condition notEmpty = lock.newCondition(); private Condition notFull = lock.newCondition(); private Queue<Object> linkedList = new LinkedList<Object>(); private int maxLenght = 10; public Object take() throws InterruptedException{ lock.lock(); try{ if(linkedList.size() == 0){ notEmpty.await(); } if(linkedList.size() == maxLenght){ notFull.signalAll(); } return linkedList.poll(); }finally{ lock.unlock(); } } public void offer(Object object) throws InterruptedException{ lock.lock(); try{ if(linkedList.size() == 0){ notEmpty.signalAll(); } if(linkedList.size() == maxLenght){ notFull.await(); } linkedList.add(object); }finally{ lock.unlock(); } } }
5,ReentrantLock和Synchronized的关系
Synchronized是lock的一种简化实现,一个lock可以对应多个Condition,而Syschronized把lock和Condition合并了,可以说Syschronized是Lock简易版本,而且效率没有lock高。
6,代替锁得办法,硬件原子操作,lockfree算法。lockfree算法分三个步骤,循环,CAS(compare and set),返回。
7,concurrentHashMap数据结构使用了lockfree的算法,支持多个writer并发。
未完待续。。。。
相关文章推荐
- java多线程和并发库 学习笔记草稿
- 学习JAVA多线程编程 --- 《JAVA多线程编程核心技术》第2章 对象及变量的并发访问 笔记
- iOS学习笔记-117.多线程16——NSOperationQueue最大并发数
- Java多线程高并发学习笔记(二)——深入理解ReentrantLock与Condition
- JAVA并发设计模式学习笔记(一)—— JAVA多线程编程
- JAVA 多线程和并发学习笔记(三)
- 黑马程序员学习笔记 Java中多线程与并发的总结
- JAVA 多线程和并发学习笔记(四)
- JAVA高并发学习笔记(二) 多线程基础
- Java学习笔记—多线程(同步容器和并发容器)
- Java多线程学习笔记—从Map开始说说同步和并发
- Java学习笔记—多线程(并发工具类)
- Java多线程与并发库高级应用 学习笔记 16-22课 +面试题
- Java多线程高并发学习笔记——阻塞队列
- Java多线程与并发库高级应用 学习笔记 10-16课
- linux网络编程学习笔记之四 -----多线程并发服务端
- JAVA 多线程和并发学习笔记(一)
- Java学习笔记—多线程(java.util.concurrent并发包概括,转载)
- JAVA 多线程和并发学习笔记(二)
- 多线程学习笔记四--------------线程间通信问题