java 并发学习笔记

      ExecutorService es2= Executors.newFixedThreadPool(2);
        ExecutorService es = Executors.newCachedThreadPool();
        ScheduledExecutorService ses = Executors.newScheduledThreadPool(1);
        
        ReentrantLock rl = new ReentrantLock();
        ReentrantReadWriteLock  rwl = new ReentrantReadWriteLock ();
        SynchronousQueue<Integer> queue = new SynchronousQueue();
        queue.add(null);
        queue.offer(null);
        
        Object a = new Object();
        a.wait(12l);
        
        CountDownLatch cd = new CountDownLatch(1);

CyclicBarrier
        cd.await();


Condition 实现可以提供不同于 Object 监视器方法的行为和语义，比如受保证的通知排序，或者在执行通知时不需要保持一个锁定。

Semaphore:
信号量维护了一个许可集合。如有必要，在许可可用前会阻塞每一个 acquire()，然后再获取该许可。每个 release() 添加一个许可，从而可能释放一个正在阻塞的获取者。

Timer
1.AbstractQueuedSynchronizer :

同步器背后的基本思想非常简单。acquire操作如下：

while (synchronization state does not allow acquire) {
enqueue current thread if not already queued;
possibly block current thread;
}
dequeue current thread if it was queued;
release操作如下：

update synchronization state;
if (state may permit a blocked thread to acquire)
unblock one or more queued threads;


AQS框架提供了一个 ConditionObject 类，给维护独占同步的类以及实现 Lock 接口的类使用。一个锁对象可以关联任意数目的条件对象
ConditionObject 使用了与同步器一样的内部队列节点。但是，是在一个单独的条件队列中维护这些节点的。 signal 操作是通过将节点从条件队列转移到锁队列中来实现的，而没有必要在需要唤醒的线程重新获取到锁之前将其唤醒
基本的await操作如下：

1
create and add new node to conditon queue;
2
release lock;
3
block until node is on lock queue;
4
re-acquire lock;
signal操作如下：

1
transfer the first node from condition queue to lock queue;


• 生成 ExecutorService 的工厂类
– newSingleThreadExecutor () ： corePoolSize = maximumPoolSize =1 ， workQueue = LinkedBlockingQueue ( 容量是 Integer.MAX_VALUE )
– newCachedThreadPool () ： corePoolSize =0 ， maximumPoolSize = Integer.MAX_VALUE ， keepAliveTime =60s ， workQueue = SynchronousQueue ( 容量是 0)
– newFixedThreadPool ( int   nThreads ) ： corePoolSize = maximumPoolSize = nThreads ， keepAliveTime =0 ， workQueue = LinkedBlockingQueue ( 容量是 Integer.MAX_VALUE )
– newSingleThreadScheduledExecutor () ：单线程，延迟执行任务
– newScheduledThreadPool ( int   corePoolSize ) ： corePoolSize ， maximum=       Integer.MAX_VALUE ， keepAliveTime =0 ， workQueue = DelayedWorkQueue


http://ifeve.com/introduce-abstractqueuedsynchronizer/