Java并发编程实现概览

<b>1.同步</b>

如何同步多个线程对共享资源的访问是多线程编程中最基本的问题之一。

当多个线程并发访问共享数据时会出现数据处于计算中间状态或者不一致的问题，从而影响到程序的正确运行。我们通常把这种情况叫做竞争条件（race condition），把并发访问共享数据的代码叫做关键区域（critical section）。

同步就是使得多个线程顺序进入关键区域从而避免竞争条件的发生。

编写线程安全的代码的核心是要对状态访问操作进行管理，尤其是对共享的和可变的状态访问。 

线程安全性的定义：当多个线程访问某个类时，这个类始终能表现出正确的行为，那么就称这个类是线程安全的。 

无状态对象一定是线程安全的。

（1）具有原子性的操作被称为原子操作

在java中，对除了long和double之外的基本类型的简单操作都具有原子性。简单操作就是赋值或者return。比如”a = 1;“和 “return a;”这样的操作都具有原子性。

在某些jvm中”a += b”可能要经过这样三个步骤：

1) 读取：取出a和b 

2) 修改：计算a+b 

3) 写入：将计算结果写入内存

非原子操作都会存在线程安全问题，需要我们使用同步技术（sychronized）来让它变成一个原子操作。concurrent包下提供了一些原子类，比如：atomicinteger、atomiclong、atomicreference等。

（2）竞争条件，指的是在并发编程中，由于不恰当的执行时序而出现不正确的结果的情况

当某个计算结果的正确性取决于多个线程的交替执行时序时就会发生竞态条件。 

常见的两种竞争条件是：“先检查后执行”和 “读取-修改-写入”。

（3）内置锁和可重入锁

java提供了一种内置锁机制来支持原子性：同步代码块。同步代码块包括两个部分：一个是作为锁的对象引用，一个是作为由这个锁保护的代码块。每个java对象都可以用作一个实现同步的锁，这些锁被称为内置锁。

当某个线程请求一个由其他线程持有的锁时，发出请求的线程就会被阻塞，然而内置锁是可以重入的。因此如果某个线程试图获得一个已经有它自己持有的锁，那么这个请求就会成功。 

注意，“锁”的持有者是实例对象，而不是类！

（1）线程安全的集合类

java.util.vector

java.util.stack

java.util.hashtable

java.util.concurrent.concurrenthashmap

java.util.concurrent.copyonwritearraylist

java.util.concurrent.copyonwritearrayset

java.util.concurrent.concurrentlinkedqueue

（2）非线程安全集合类

java.util.bitset

java.util.hashset (linkedhashset)

java.util.treeset

java.util.hashmap (weekhashmap, treemap, linkedhashmap, identityhashmap)

java.util.arraylist (linkedlist)

java.util.priorityqueue

这些非线程安全的集合可以通过java.util.collections.synchronizedlist、synchronizedmap、synchronizedset等方法包装成线程安全的集合。包装器类简单地给被包装集合的各项操作加上了synchronized保护。值得注意的是在使用游标遍历这些包装器集合的时候必须加上额外的synchronized保护，否则会出现问题。

1

2

3

4

5

6

7

<code>list list = collections.synchronizedlist(</code><code>new</code> <code>arraylist()); </code>

<code>    </code><code>... </code>

<code>synchronized</code><code>(list) { </code>

<code>    </code><code>iterator i = list.iterator(); </code><code>// must be in synchronized block </code>

<code>    </code><code>while</code> <code>(i.hasnext()) </code>

<code>        </code><code>foo(i.next()); </code>

<code>} </code>

　　

（3）线程通知集合类

java.util.concurrent.arrayblockingqueue

java.util.concurrent.linkedblockingqueue

java.util.concurrent.synchronousqueue

java.util.concurrent.priorityblockingqueue

java.util.concurrent.delayqueue

这些集合类都实现了blockingqueue接口。阻塞队列的特点是当从队列中取出元素时如果队列为空，线程会被阻塞直到队列中有元素被插入。当从队列中插入元素时如果队列已满，线程会被阻塞直到队列中有元素被取出出现空闲空间。阻塞队列可以用来实现生产者消费者模式(producer/consumer pattern) 。

频繁地创建和销毁线程会降低程序的性能。

应用程序可以创建线程的数量是受机器物理条件制约的，过多的线程会耗尽机器的资源，在设计程序的时候需要限制并发线程的数量。

线程池在启动的时候一次性初始化若干个线程（也可以根据负载按需启动，也有闲置一定时间的线程会被销毁的策略），然后程序把任务交给线程池去执行而不是直接交给某个线程执行，由线程池给这些任务分配线程。

当某个线程执行完一个任务后，线程池会把它设成空闲状态以备下一个任务重用而不是销毁它。

线程池在初始化的时候需要指定线程数量上限，当并发任务数量超过线程数量的时候，

线程池不会再创建新的线程而是让新任务等待，这样我们就不在需要担心线程数量过多耗尽系统资源了。jdk1.5开始为我们提供了标准的线程池。

（1）executor接口

java的线程池实现了以下executor接口：

<code>java的线程池实现了以下executor接口：        </code>

<code>public</code> <code>interface</code> <code>executor { </code>

<code>    </code><code>void</code> <code>execute(runnable command); </code>

<code>}</code>

在多线程编程中，执行器是一种常用的设计模式，它的好处在于提供了一种简单有效的编程模型，我们只需把需要并发处理的工作拆分成独立的任务，然后交给执行器去执行即可而不必关心线程的创建，分配和调度。

jdk主要提供了两种功能的执行器：threadpoolexecutor和scheduledthreadpoolexecutor。threadpoolexecutor是基本的线程池实现，scheduledthreadpoolexecutor在前者基础上增加了任务调度的功能，在把任务交给它时我们可以指定任务的执行时间，而不是立刻执行。

（2）executors创建线程池

java.util.concurrent.executors是用来创建线程池的工厂类，

通过它提供的工厂方法，我们可以方便地创建不同特性的线程池，包括缓存线程池、各种优先级线程池等。

（3）future接口

executor接口并没有看起来那么理想，有时候我们执行一个任务是要得到计算的结果，有时候我们需要对任务有更多控制，例如知道它是否完成，或者中途终止它。返回void的execute方法并不能满足我们这些需求。当然我们可以在传入的runnable类上下功夫来提供类似的功能，但是这样做繁琐且容易出错。实际上线程池实现了一个更为丰富的executorservice接口，它定义了执行任务并返回代表该任务的future对象的submit方法。

通过future接口，我们可以查看已经被提交给线程池执行的任务是否完成，获取执行的结果或者终止任务。

（4） runnable 和callable 接口

实现了runnable或callable接口的类都可以作为任务提交给线程池执行，这两个接口的主要区别在于callable的call方法有结果返回并且可以抛出异常而runnable的run方法返回void且不允许有可检查的异常抛出（只能抛runtime exception）。因此如果我们的任务执行后有结果返回，应该使用callable接口。

协调共享对象访问的机制：jdk5之前是synchronized和volatile()，jdk5增加了reentrantlock，现在可以用lock显式的lock()和unlock()，并且有定时锁，读写锁等。

（1）reentrantlock

reentrantlock实现了lock接口，并提供了与synchronized相同的互斥性和内存可见性。

8

9

10

<code>public</code> <code>interface</code> <code>lock {</code>

<code>void</code> <code>lock();</code>

<code>//如果当前线程未被中断，则获取锁定。</code>

<code>    </code><code>void</code> <code>lockinterruptibly() </code><code>throws</code> <code>interruptedexception;</code>

<code>    </code><code>boolean</code> <code>trylock();</code>

<code>    </code><code>boolean</code> <code>trylock(</code><code>long</code> <code>timeout, timeunit unit)</code>

<code>    </code><code>throws</code> <code>interruptedexception;</code>

<code>    </code><code>void</code> <code>unlock();</code>

<code>    </code><code>condition newcondition();</code>

使用reentrantlock来保护对象状态。

<code>lock lock = </code><code>new</code> <code>reentrantlock();</code>

<code>lock.lock();</code>

<code>try</code> <code>{</code>

<code>    </code><code>//相关操作</code>

<code>} </code><code>finally</code> <code>{</code>

<code>    </code><code>lock.unlock();  </code><code>//一定要释放锁</code>

（2）轮询锁和定时锁

可定时的与可轮询的锁获取模式是由trylock方法实现的，与无条件的锁获取模式相比，它具有更完善的错误恢复机制。

（3）可中断的锁

（4）readwritelock 读-写锁

readwritelock 维护了一对相关的锁定，一个用于只读操作，另一个用于写入操作。

//readwritelock 接口

<code>//readwritelock 接口</code>

<code>public</code> <code>interface</code> <code>readwritelock {</code>

<code>    </code><code>lock readlock();</code>

<code>    </code><code>lock writelock();</code>

（1）countdownlatch，计数器或者闭锁

countdownlatch是一个同步辅助类，java.util.concurrent.countdownlatch，在完成一组正在其他线程中执行的操作之前，它允许一个或多个线程一直等待。用给定的计数 初始化 countdownlatch。由于调用了 countdown() 方法，所以在当前计数到达零之前，await 方法会一直受阻塞。之后，会释放所有等待的线程，await 的所有后续调用都将立即返回。这种现象只出现一次——计数无法被重置。

countdownlatch即一个线程(或者多个)， 等待另外n个线程完成某个事情之后才能执行

（2）cyclicbarrier，栅栏

通过闭锁（countdownlatch）来同时启动一组相关线程，或等待一组相关线程的结束。可是闭锁是一次性对象，一旦进入终止状态，就不能被重置。栅栏类似于闭锁，它能够阻塞一组线程直到某个事件发生。

cyclicbarrier在并行迭代算法中是非常有用。

计数信号量（counting semaphore）用来控制同时访问某个特定资源的操作数量，或者同时执行某个指定操作的数量。

有时候我们有多个相同的共享资源可以同时被多个线程使用。我们希望在锁的基础上加上一个计数器，根据资源的个数来初始化这个计数器，每次成功的lock操作都会使计数器的值减去1，只要计数器的值不为零就表示还有资源可以使用，lock操作就能成功。每次unlock操作都会给这个计数器加1。只有当计数器的值为0的时候lock操作才会阻塞当前线程。这就是java中的信号量semaphore。

semaphore类提供的方法和lock接口非常类似，当把信号量的资源个数设置成1时，信号量就退化为普通的锁。

（1）是变量不是线程

如果每个线程都有自己私有的成员变量，那么我们也不需要同步。threadlocal就是线程的私有变量，每个使用threadlocal变量的线程都会有自己独立的threadlocal对象，因此就不存在多个线程访问同一个变量的问题。

它并不是一个thread，而是threadlocalvariable(线程局部变量)。

（2）threadlocal 的实现原理

每个thread对象有自己用来存储私有threadlocal对象的容器threadlocalmap，当某个线程调用threadlocal对象的get()方法来 取值的时候，

get方法首先会取得当前线程对象，然后取出该线程的threadlocalmap，然后检查自己是否已经在map中，如果自己已经存在，直接返回map中的value。

如果不存在，把自己作key并初始化一个value加入到当前线程的map中。

<code>public</code> <code>t get() { </code>

<code>        </code><code>thread t = thread.currentthread(); </code>

<code>        </code><code>threadlocalmap map = getmap(t); </code>

<code>        </code><code>if</code> <code>(map != </code><code>null</code><code>) { </code>

<code>            </code><code>threadlocalmap.entry e = map.getentry(</code><code>this</code><code>); </code>

<code>            </code><code>if</code> <code>(e != </code><code>null</code><code>) </code>

<code>                </code><code>return</code> <code>(t)e.value; </code>

<code>        </code><code>} </code>

<code>        </code><code>return</code> <code>setinitialvalue(); </code>