本文是的Java并发相关的教程，感谢的翻译和投递。 

（关注，随时随地查看最新开发资讯、技术文章。） 

计算机的使用者一直以为他们的计算机可以同时做很多事情。他们认为当其他的应用程序在下载文件，管理打印队列或者缓冲音频的时候他们可以继续在文字处理程序上工作。甚至对于单个应用程序，他们任然期待它能在在同一时间做很多事情。举个例子，一个流媒体播放程序必须能同时完成以下工作：从网络上读取数字音频，解压缩数字音频，管理播放和更新程序显示。甚至文字处理器也应该能在忙于重新格式化文本和刷新显示的情况下同时响应键盘和鼠标事件。这样的软件就被称为并发软件。 

通过Java语言和Java类库对于基础并发的支持，Java平台具有完全（from the ground up ）支持并发编程的能力。从JDK5.0起，Java平台还引入了高级并发APIs。这个课程不仅涵盖了Java平台基础并发内容，还对高级并发APIs有一定的阐述。

目 录 

进程和线程

（本部分，，译者：bjsuo，校对：郑旭东） 
在并发编程中，有两个基本的执行单元：进程和线程。在java语言中，并发编程最关心的是线程，然而，进程也是非常重要的。 

即使在只有单一的执行核心的计算机系统中，也有许多活动的进程和线程。因此，在任何给定的时刻，只有一个线程在实际执行。处理器的处理时间是通过操作系统的时间片在进程和线程中共享的。 

现在具有多处理器或有多个执行内核的多处理器的计算机系统越来越普遍，这大大增强了系统并发执行的进程和线程的吞吐量–但在不没有多个处理器或执行内核的简单的系统中，并发任然是可能的。 

进程 

进程具有一个独立的执行环境。通常情况下，进程拥有一个完整的、私有的基本运行资源集合。特别地，每个进程都有自己的内存空间。 

进程往往被看作是程序或应用的代名词，然而，用户看到的一个单独的应用程序实际上可能是一组相互协作的进程集合。为了便于进程之间的通信，大多数操作系统都支持进程间通信（IPC），如pipes 和sockets。IPC不仅支持同一系统上的通信，也支持不同的系统。 

Java虚拟机的大多数实现是单进程的。Java应用可以使用的ProcessBuilder对象创建额外的进程，多进程应用超出了本课的范围。 

线程 

线程有时也被称为轻量级的进程。进程和线程都提供了一个执行环境，但创建一个新的线程比创建一个新的进程需要的资源要少。 

线程是在进程中存在的 — 每个进程最少有一个线程。线程共享进程的资源，包括内存和打开的文件。这样提高了效率，但潜在的问题就是线程间的通信。 

多线程的执行是Java平台的一个基本特征。每个应用都至少有一个线程 – 或几个，如果算上“系统”线程的话，比如内存管理和信号处理等。但是从程序员的角度来看，启动的只有一个线程，叫主线程。这个线程有能力创建额外的线程，我们将在下一节演示。 

线程对象

（本部分，，译者：郑旭东） 
在Java中，每个线程都是类的实例。并发应用中一般有两种不同的线程创建策略。 

• 直接控制线程的创建和管理，每当应用程序需要执行一个异步任务的时候就为其创建一个线程
• 将线程的管理从应用程序中抽象出来作为执行器，应用程序将任务传递给执行器，有执行器负责执行。

这一节，我们将讨论Thread对象，有关Executors将在高级并发对象一节中讨论。 

定义并启动一个线程 

应用程序在创建一个线程实例时，必须提供需要在线程中运行的代码。有两种方式去做到这一点： 

• 提供一个Runnable对象。对象仅包含一个run()方法，在这个方法中定义的代码将在会线程中执行。将Runnable对象传递给Thread类的构造函数即可，如下面这个的例子：

Java代码 

1. public class HelloRunnable implements Runnable {  
2.   
3.     public void run() {  
4.         System.out.println("Hello from a thread!");  
5.     }  
6.   
7.     public static void main(String args[]) {  
8.         (new Thread(new HelloRunnable())).start();  
9.     }  
10.   
11. }  

• 继承Thread类。Thread类自身已实现了Runnable接口，但它的run()方法中并没有定义任何代码。应用程序可以继承与Thread类，并复写run()方法。如例子

Java代码 

1. public class HelloThread extends Thread {  
2.   
3.     public void run() {  
4.         System.out.println("Hello from a thread!");  
5.     }  
6.   
7.     public static void main(String args[]) {  
8.         (new HelloThread()).start();  
9.     }  
10.   
11. }  

需要注意的是，上述两个例子都需要调用Thread.start()方法来启动一个新的线程。 哪一种方式是我们应该使用的？相对来说，第一种更加通用，因为Runnable对象可以继承于其他类（Java只支持单继承，当一个类继承与Thread类后，就无法继承与其他类）。第二种方法更易于在简单的应用程序中使用，但它的局限就是：你的任务类必须是Thread的子类。这个课程更加聚焦于第一种将Runnable任务和Thread类分离的方式。不仅仅是因为这种方式更加灵活，更因为它更适合后面将要介绍的高级线程管理API。 Thread类定义了一些对线程管理十分有用的的方法。在这些方法中，有一些静态方法可以给当前线程调用，它们可以提供一些有关线程的信息，或者影响线程的状态。而其他一些方法可以由其他线程进行调用，用于管理线程和Thread对象。我们将在下面的章节中，深入探讨这些内容。 

使用Sleep方法暂停一个线程 

使用Thread.sleep()方法可以暂停当前线程一段时间。这是一种使处理器时间可以被其他线程或者运用程序使用的有效方式。sleep()方法还可以用于调整线程执行节奏（见下面的例子）和等待其他有执行时间需求的线程（这个例子将在下一节演示）。 
在Thread中有两个不同的sleep()方法，一个使用毫秒表示休眠的时间，而另一个是用纳秒。由于操作系统的限制休眠时间并不能保证十分精确。休眠周期可以被interrups所终止，我们将在后面看到这样的例子。不管在任何情况下，我们都不应该假定调用了sleep()方法就可以将一个线程暂停一个十分精确的时间周期。 

程序为我们展示了使用sleep()方法每四秒打印一个信息的例子 

Java代码 

1. public class SleepMessages {  
2.     public static void main(String args[])  
3.         throws InterruptedException {  
4.         String importantInfo[] = {  
5.             "Mares eat oats",  
6.             "Does eat oats",  
7.             "Little lambs eat ivy",  
8.             "A kid will eat ivy too"  
9.         };  
10.   
11.         for (int i = 0;  
12.              i < importantInfo.length;  
13.              i++) {  
14.             //Pause for 4 seconds  
15.             Thread.sleep(4000);  
16.             //Print a message  
17.             System.out.println(importantInfo[i]);  
18.         }  
19.     }  
20. }  

main()方法声明了它有可能抛出InterruptedException。当其他线程中断当前线程时，sleep()方法就会抛出该异常。由于这个应用程序并没有定义其他的线程，所以并不用关心如何处理该异常。 

中断（Interrupts） 

中断是给线程的一个指示，告诉它应该停止正在做的事并去做其他事情。一个线程究竟要怎么响应中断请求取决于程序员，不过让其终止是很普遍的做法。这是本文重点强调的用法。 

一个线程通过调用对被中断线程的Thread对象的interrupt()方法，发送中断信号。为了让中断机制正常工作，被中断的线程必须支持它自己的中断（即要自己处理中断） 

中断支持 

线程如何支持自身的中断？这取决于它当前正在做什么。如果线程正在频繁调用会抛InterruptedException异常的方法，在捕获异常之后，它只是从run()方法中返回。例如，假设在SleepMessages的例子中，关键的消息循环在线程的Runnable对象的run方法中，代码可能会被修改成下面这样以支持中断： 

Java代码 

1. for (int i = 0; i < importantInfo.length; i++) {  
2.     // Pause for 4 seconds  
3.     try {  
4.        Thread.sleep(4000);  
5.     } catch (InterruptedException e) {  
6.        // We‘ve been interrupted: no more messages.  
7.       return;  
8.  }  
9.  // Print a message  
10.  System.out.println(importantInfo[i]);  
11. }  

许多会抛InterruptedException异常的方法(如sleep()），被设计成接收到中断后取消它们当前的操作，并在立即返回。 

如果一个线程长时间运行而不调用会抛InterruptedException异常的方法会怎样？ 那它必须周期性地调用Thread.interrupted()方法，该方法在接收到中断请求后返回true。例如： 

Java代码 

1. for (int i = 0; i < inputs.length; i++) {  
2.     heavyCrunch(inputs[i]);  
3.     if (Thread.interrupted()) {  
4.         // We‘ve been interrupted: no more crunching.  
5.         return;  
6.     }  
7. }  

在这个简单的例子中，代码只是检测中断，并在收到中断后退出线程。在更复杂的应用中，抛出一个InterruptedException异常可能更有意义。 

Java代码 

1. if (Thread.interrupted()){  
2.    throw new InterruptedException();  
3. }  

这使得中断处理代码能集中在catch语句中。 

中断状态标记 

中断机制通过使用称为中断状态的内部标记来实现。调用Thread.interrupt()设置这个标记。当线程通过调用静态方法Thread.interrupted()检测中断时，中断状态会被清除。非静态的isInterrupted()方法被线程用来检测其他线程的中断状态，不改变中断状态标记。 

按照惯例，任何通过抛出一个InterruptedException异常退出的方法，当抛该异常时会清除中断状态。不过，通过其他的线程调用interrupt()方法，中断状态总是有可能会立即被重新设置。 

Joins 

Join()方法可以让一个线程等待另一个线程执行完成。若t是一个正在执行的Thread对象， 

Java代码 

1. t.join();  

将会使当前线程暂停执行并等待t执行完成。重载的join()方法可以让开发者自定义等待周期。然而，和sleep()方法一样join()方法依赖于操作系统的时间处理机制，你不能假定join()方法将会精确的等待你所定义的时长。 
如同sleep()方法，join()方法响应中断并在中断时抛出InterruptedException。 

一个简单的线程例子 

下面这个简单的例子将会把这一节的一些概念放到一起演示。程序有两个线程组成，第一个是主线程，它从创建了一个线程并等待它执行完成。如果MessageLoop线程执行了太长时间，主线程将会将其中断。 
MessageLoop现场将会打印一系列的信息。如果中断在它打印完所有信息前发生，它将会打印一个特定的消息并退出。 

Java代码 

1. public class SimpleThreads {  
2.   
3.     // Display a message, preceded by  
4.     // the name of the current thread  
5.     static void threadMessage(String message) {  
6.         String threadName =  
7.             Thread.currentThread().getName();  
8.         System.out.format("%s: %s%n",  
9.                           threadName,  
10.                           message);  
11.     }  
12.   
13.     private static class MessageLoop  
14.         implements Runnable {  
15.         public void run() {  
16.             String importantInfo[] = {  
17.                 "Mares eat oats",  
18.                 "Does eat oats",  
19.                 "Little lambs eat ivy",  
20.                 "A kid will eat ivy too"  
21.             };  
22.             try {  
23.                 for (int i = 0;  
24.                      i < importantInfo.length;  
25.                      i++) {  
26.                     // Pause for 4 seconds  
27.                     Thread.sleep(4000);  
28.                     // Print a message  
29.                     threadMessage(importantInfo[i]);  
30.                 }  
31.             } catch (InterruptedException e) {  
32.                 threadMessage("I wasn‘t done!");  
33.             }  
34.         }  
35.     }  
36.   
37.     public static void main(String args[])  
38.         throws InterruptedException {  
39.   
40.         // Delay, in milliseconds before  
41.         // we interrupt MessageLoop  
42.         // thread (default one hour).  
43.         long patience = 1000 * 60 * 60;  
44.   
45.         // If command line argument  
46.         // present, gives patience  
47.         // in seconds.  
48.         if (args.length > 0) {  
49.             try {  
50.                 patience = Long.parseLong(args[0]) * 1000;  
51.             } catch (NumberFormatException e) {  
52.                 System.err.println("Argument must be an integer.");  
53.                 System.exit(1);  
54.             }  
55.         }  
56.   
57.         threadMessage("Starting MessageLoop thread");  
58.         long startTime = System.currentTimeMillis();  
59.         Thread t = new Thread(new MessageLoop());  
60.         t.start();  
61.   
62.         threadMessage("Waiting for MessageLoop thread to finish");  
63.         // loop until MessageLoop  
64.         // thread exits  
65.         while (t.isAlive()) {  
66.             threadMessage("Still waiting...");  
67.             // Wait maximum of 1 second  
68.             // for MessageLoop thread  
69.             // to finish.  
70.             t.join(1000);  
71.             if (((System.currentTimeMillis() - startTime) > patience)  
72.                   && t.isAlive()) {  
73.                 threadMessage("Tired of waiting!");  
74.                 t.interrupt();  
75.                 // Shouldn‘t be long now  
76.                 // -- wait indefinitely  
77.                 t.join();  
78.             }  
79.         }  
80.         threadMessage("Finally!");  
81.     }  
82. }  

同步

（本部分，，译者：蘑菇街-小宝，，  校对：丁一，郑旭东，） 
线程间的通信主要是通过共享域和引用相同的对象。这种通信方式非常高效，不过可能会引发两种错误：线程干扰和内存一致性错误。防止这些错误发生的方法是同步。 

不过，同步会引起线程竞争，当两个或多个线程试图同时访问相同的资源，随之就导致Java运行时环境执行其中一个或多个线程比原先慢很多，甚至执行被挂起，这就出现了线程竞争。线程饥饿和活锁都属于线程竞争的范畴。关于线程竞争的更多信息可参考活跃度一节。 

本节内容包括以下这些主题： 

• 线程干扰讨论了当多个线程访问共享数据时错误是怎么发生的。
• 内存一致性错误讨论了不一致的共享内存视图导致的错误。
• 同步方法讨论了 一种能有效防止线程干扰和内存一致性错误的常见做法。
• 内部锁和同步讨论了更通用的同步方法，以及同步是如何基于内部锁实现的。
• 原子访问讨论了不能被其他线程干扰的操作的总体思路。

1.  线程干扰 

下面这个简单的Counter类： 

Java代码 

1. class Counter {  
2.     private int c = 0;  
3.     public void increment() {  
4.         c++;  
5.     }  
6.     public void decrement() {  
7.         c--;  
8.     }  
9.     public int value() {  
10.         return c;  
11.     }  
12. }  

Counter类被设计成：每次调用increment()方法，c的值加1；每次调用decrement()方法，c的值减1。如果当同一个Counter对象被多个线程引用，线程间的干扰可能会使结果同我们预期的不一致。 

当两个运行在不同的线程中却作用在相同的数据上的操作交替执行时，就发生了线程干扰。这意味着这两个操作都由多个步骤组成，而步骤间的顺序产生了重叠。 

Counter类实例的操作会交替执行，这看起来似乎不太可能，因为c上的这两个操作都是单一而简单的语句。然而，即使一个简单的语句也会被虚拟机转换成多个步骤。我们不去深究虚拟机内部的详细执行步骤——理解c++这个单一的语句会被分解成3个步骤就足够了： 

• 获取当前c的值；
• 对获取到的值加1；
• 把递增后的值写回到c；

语句c–也可以按同样的方式分解，除了第二步的操作是递减而不是递增。 

假设线程A调用increment()的同时线程B调用decrement().如果c的初始值为0，线程A和B之间的交替执行顺序可能是下面这样： 

• 线程A：获取c；
• 线程B：获取c；
• 线程A：对获取的值加1，结果为1；
• 线程B：对获取的值减1，结果为-1；
• 线程A：结果写回到c,c现在是1；
• 线程B：结果写回到c,c现在是-1；

线程A的结果因为被线程B覆盖而丢失了。这个交替执行的结果只是其中一种可能性。在不同的环境下，可能是线程B的结果丢失了，也可能是不会出任何问题。由于结果是不可预知的，所以线程干扰的bug很难检测和修复。 

2.  内存一致性错误 

当不同的线程对相同的数据产生不一致的视图时会发生内存一致性错误。内存一致性错误的原因比较复杂，也超出了本教程的范围。不过幸运的是，一个程序员并不需要对这些原因有详细的了解。所需要的是避免它们的策略。 

避免内存一致性错误的关键是理解happens-before关系。这种关系只是确保一个特定语句的写内存操作对另外一个特定的语句可见。要说明这个问题，请参考下面的例子。假设定义和初始化了一个简单int字段： 

Java代码 

1. int counter =0 ;  

这个counter字段被A，B两个线程共享。假设线程A对counter执行递增: 

Java代码 

1. counter++;  

然后，很快的，线程B输出counter: 

Java代码 

1. System.out.println(counter);  

如果这两个语句已经在同一个线程中被执行过，那么输出的值应该是“1”。不过如果这两个语句在不同的线程中分开执行，那输出的值很可能是“0”，因为无法保证线程A对counter的改动对线程B是可见的——除非我们在这两个语句之间已经建立了happens-before关系。 

有许多操作会建立happens-before关系。其中一个是同步，我们将在下面的章节中看到。 
我们已经见过两个建立happens-before关系的操作。 

当一条语句调用Thread.start方法时，和该语句有happens-before关系的每一条语句，跟新线程执行的每一条语句同样有happens-before关系。创建新线程之前的代码的执行结果对线新线程是可见的。 

当一个线程终止并且当导致另一个线程中Thread.join返回时，被终止的线程执行的所有语句和在join返回成功之后的所有语句间有happens-before关系。线程中代码的执行结果对执行join操作的线程是可见的。 

要查看建立happens-before关系的操作列表，请参阅java.util.concurrent包的。 

3.  同步方法 

Java编程语言提供两种同步方式：同步方法和同步语句。相对较复杂的同步语句将在下一节中介绍。本节主要关注同步方法。 

要让一个方法成为同步方法，只需要在方法声明中加上synchronized关键字： 

Java代码 

1. public class SynchronizedCounter {  
2.     private int c = 0;  
3.   
4.     public synchronized void increment() {  
5.         c++;  
6.     }  
7.   
8.     public synchronized void decrement() {  
9.         c--;  
10.     }  
11.   
12.     public synchronized int value() {  
13.         return c;  
14.     }  
15. }  

如果count是SynchronizedCounter类的实例，那么让这些方法成为同步方法有两个作用: 
首先，相同对象上的同步方法的两次调用，它们要交替执行是不可能的。 当一个线程正在执行对象的同步方法时，所有其他调用该对象同步方法的线程会被阻塞（挂起执行）,直到第一个线程处理完该对象。 

其次，当一个同步方法退出时，它会自动跟该对象同步方法的任意后续调用建立起一种happens-before关系。这确保对象状态的改变对所有线程是可见的。 

注意构造方法不能是同步的——构造方法加synchronized关键字会报语法错误。同步的构造方法没有意义，因为当这个对象被创建的时候，只有创建对象的线程能访问它。 

警告：当创建的对象会被多个线程共享时必须非常小心，对象的引用不要过早“暴露”出去。比如，假设你要维护一个叫instances的List，它包含类的每一个实例对象。你可能会尝试在构造方法中加这样一行： 

Java代码 

1. instances.add(this);  

不过其他线程就能够在对象构造完成之前使用instances访问对象。 

同步(synchronized)方法使用一种简单的策略来防止线程干扰和内存一致性错误：如果一个对象对多个线程可见，对象域上的所有读写操作都是通过synchronized方法来完成的。（一个重要的例外：final域，在对象被创建后不可修改,能被非synchronized方法安全的读取）。synchronized同步策略很有效，不过会引起活跃度问题，我们将在本节后面看到。 

4.  内部锁与同步 

同步机制的建立是基于其内部一个叫内部锁或者监视锁的实体。（在Java API规范中通常被称为监视器。）内部锁在同步机制中起到两方面的作用：对一个对象的排他性访问；建立一种happens-before关系，而这种关系正是可见性问题的关键所在。 

每个对象都有一个与之关联的内部锁。通常当一个线程需要排他性的访问一个对象的域时，首先需要请求该对象的内部锁，当访问结束时释放内部锁。在线程获得内部锁到释放内部锁的这段时间里，我们说线程拥有这个内部锁。那么当一个线程拥有一个内部锁时，其他线程将无法获得该内部锁。其他线程如果去尝试获得该内部锁，则会被阻塞。 

当线程释放一个内部锁时，该操作和对该锁的后续请求间将建立happens-before关系。 

5.  同步方法中的锁 

当线程调用一个同步方法时，它会自动请求该方法所在对象的内部锁。当方法返回结束时则自动释放该内部锁，即使退出是由于发生了未捕获的异常，内部锁也会被释放。 

你可能会问调用一个静态的同步方法会如何，由于静态方法是和类（而不是对象）相关的，所以线程会请求类对象(Class Object)的内部锁。因此用来控制类的静态域访问的锁不同于控制对象访问的锁。 

6.  同步块 

另外一种同步的方法是使用同步块。和同步方法不同，同步块必须指定所请求的是哪个对象的内部锁： 
Java代码 

1. public void addName(String name) {  
2.     synchronized(this) {  
3.         lastName = name;  
4.         nameCount++;  
5.     }  
6.     nameList.add(name);  
7. }  

在上面的例子中，addName方法需要使lastName和nameCount的更改保持同步，而且要避免同步调用该对象的其他方法。（在同步代码中调用其他方法会产生一节所描述的问题。）如果不使用同步块，那么必须要定义一个额外的非同步方法，而这个方法仅仅是用来调用nameList.add。 

使用同步块对于更细粒度的同步很有帮助。例如类MsLunch有两个实例域c1和c2，他们并不会同时使用（译者注：即c1和c2是彼此无关的两个域），所有对这两个域的更新都需要同步，但是完全不需要防止c1的修改和c2的修改相互之间干扰（这样做只会产生不必要的阻塞而降低了并发性）。这种情况下不必使用同步方法，可以使用和this对象相关的锁。这里我们创建了两个“锁”对象（译者注：起到加锁效果的普通对象lock1和lock2）。 

Java代码 

1. public class MsLunch {  
2.     private long c1 = 0;  
3.     private long c2 = 0;  
4.     private Object lock1 = new Object();  
5.     private Object lock2 = new Object();  
6.   
7.     public void inc1() {  
8.         synchronized(lock1) {  
9.             c1++;  
10.         }  
11.     }  
12.   
13.     public void inc2() {  
14.         synchronized(lock2) {  
15.             c2++;  
16.         }  
17.     }  
18. }  

使用这种方法时要特别小心，需要十分确定c1和c2是彼此无关的域。 

7.  可重入同步 

还记得吗，一个线程不能获得其他线程所拥有的锁。但是它可以获得自己已经拥有的锁。允许一个线程多次获得同一个锁实现了可重入同步。这里描述了一种同步代码的场景，直接的或间接地，调用了一个也拥有同步代码的方法，且两边的代码使用的是同一把锁。如果没有这种可重入的同步机制，同步代码则需要采取许多额外的预防措施以防止线程阻塞自己。 

8.  原子访问 

在编程过程中，原子操作是指所有操作都同时发生。原子操作不能被中途打断：要么全做，要么不做。原子操作在完成前不会有看得见的副作用。 

我们发现像c++这样的增量表达式，并没有描述原子操作。即使是非常简单的表达式也能够定义成能被分解为其他操作的复杂操作。然而，有些操作你可以定义为原子的： 

• 对引用变量和大部分基本类型变量（除long和double之外）的读写是原子的。
• 对所有声明为volatile的变量（包括long和double变量）的读写是原子的。

原子操作不会交错，于是可以放心使用，不必担心线程干扰。然而，这并不能完全消除原子操作上的同步，因为内存一致性错误仍可能发生。使用volatile变量可以降低内存一致性错误的风险，因为对volatile变量的任意写操作，对于后续在该变量上的读操作建立了happens-before关系。这意味着volatile变量的修改对于其他线程总是可见的。更重要的是，这同时也意味着当一个线程读取一个volatile变量时，它不仅能看到该变量最新的修改，而且也能看到致使该改变发生的代码的副效应。 

使用简单的原子变量访问比通过同步代码来访问更高效，但是需要程序员更加谨慎以避免内存一致性错误。至于这额外的付出是否值得，得看应用的大小和复杂度。 

java.util.concurrent包中的一些类提供了一些不依赖同步机制的原子方法。我们将在高级并发对象这一节中讨论它们。 

活跃度

（本部分，，译者：，郑旭东 校对：） 
一个并发应用程序能及时执行的能力称为活跃性。本节将介绍最常见的活跃性问题：死锁（deadlock），以及另外两个活跃性问题：饥饿（starvation）和活锁（livelock）。 

1.  死锁 

死锁描述了这样一种情景，两个或多个线程永久阻塞，互相等待对方释放资源。下面是一个例子。 

Alphone和Gaston是朋友，都很讲究礼节。礼节有一个严格的规矩，当你向一个朋友鞠躬时，你必须保持鞠躬的姿势，直到你的朋友有机会回鞠给你。不幸的是，这个规矩没有算上两个朋友相互同时鞠躬的可能。 

下面的应用例子，DeadLock，模拟了这个可能性。 

Java代码 

1.    static class Friend {  
2.         private final String name;  
3.         public Friend(String name) {  
4.             this.name = name;  
5.         }  
6.         public String getName() {  
7.             return this.name;  
8.         }  
9.         public synchronized void bow(Friend bower) {  
10.             System.out.format("%s: %s"  
11.                 + "  has bowed to me!%n",  
12.                 this.name, bower.getName());  
13.             bower.bowBack(this);  
14.         }  
15.         public synchronized void bowBack(Friend bower) {  
16.             System.out.format("%s: %s"  
17.                 + " has bowed back to me!%n",  
18.                 this.name, bower.getName());  
19.         }  
20.     }  
21.   
22.     public static void main(String[] args) {  
23.         final Friend alphonse =  
24.             new Friend("Alphonse");  
25.         final Friend gaston =  
26.             new Friend("Gaston");  
27.         new Thread(new Runnable() {  
28.             public void run() { alphonse.bow(gaston); }  
29.         }).start();  
30.         new Thread(new Runnable() {  
31.             public void run() { gaston.bow(alphonse); }  
32.         }).start();  
33.     }  
34. }  

当DeadLock运行后，两个线程极有可能阻塞，当它们尝试调用bowBack方法时。没有哪个阻塞会结束，因为每个线程都在等待另一个线程退出bow方法。 

2.  饥饿和活锁 

饥饿和活锁并不如死锁一般普遍，但它仍然是每个并发程序设计者可能会遇到的问题。 

饥饿 

饥饿是指当一个线程不能正常的访问共享资源并且不能正常执行的情况。这通常在共享资源被其他“贪心”的线程长期时发生。举个例子，假设一个对象提供了一个同步方法，这个方法通常需要执行很长一段时间才返回。如果一个线程经常调用这个方法，那么其他需要同步的访问这个对象的线程就经常会被阻塞。 

活锁 

一个线程通常会有会响应其他线程的活动。如果其他线程也会响应另一个线程的活动，那么就有可能发生活锁。同死锁一样，发生活锁的线程无法继续执行。然而线程并没有阻塞——他们在忙于响应对方无法恢复工作。这就相当于两个在走廊相遇的人：Alphonse向他自己的左边靠想让Gaston过去，而Gaston向他的右边靠想让Alphonse过去。可见他们阻塞了对方。Alphonse向他的右边靠，而Gaston向他的左边靠，他们还是阻塞了对方。 

保护块（Guarded Blocks）

（本部分，，译者：Greester，校对：郑旭东） 
多线程之间经常需要协同工作，最常见的方式是使用Guarded Blocks，它循环检查一个条件（通常初始值为true），直到条件发生变化才跳出循环继续执行。在使用Guarded Blocks时有以下几个步骤需要注意： 

假设guardedJoy()方法必须要等待另一线程为共享变量joy设值才能继续执行。那么理论上可以用一个简单的条件循环来实现，但在等待过程中guardedJoy方法不停的检查循环条件实际上是一种资源浪费。 

Java代码 

1. public void guardedJoy() {  
2.     // Simple loop guard. Wastes  
3.     // processor time. Don‘t do this!  
4.     while(!joy) {}  
5.     System.out.println("Joy has been achieved!");  
6. }  

更加高效的方法是调用Object.wait将当前线程挂起，直到有另一线程发起事件通知（尽管通知的事件不一定是当前线程等待的事件）。 

Java代码 

1. public synchronized void guardedJoy() {  
2.     // This guard only loops once for each special event, which may not  
3.     // be the event we‘re waiting for.  
4.     while(!joy) {  
5.         try {  
6.             wait();  
7.         } catch (InterruptedException e) {}  
8.     }  
9.     System.out.println("Joy and efficiency have been achieved!");  
10. }  

注意：一定要在循环里面调用wait方法，不要想当然的认为线程唤醒后循环条件一定发生了改变。 

和其他可以暂停线程执行的方法一样，wait方法会抛出InterruptedException，在上面的例子中，因为我们关心的是joy的值，所以忽略了InterruptedException。 

为什么guardedJoy是synchronized方法？假设d是用来调用wait的对象，当一个线程调用d.wait，它必须要拥有d的内部锁（否则会抛出异常），获得d的内部锁的最简单方法是在一个synchronized方法里面调用wait。 

当一个线程调用wait方法时，它释放锁并挂起。然后另一个线程请求并获得这个锁并调用通知所有等待该锁的线程。 

Java代码 

1. public synchronized notifyJoy() {  
2.     joy = true;  
3.     notifyAll();  
4. }  

当第二个线程释放这个该锁后，第一个线程再次请求该锁，从wait方法返回并继续执行。 

注意：还有另外一个通知方法，notify()，它只会唤醒一个线程。但由于它并不允许指定哪一个线程被唤醒，所以一般只在大规模并发应用（即系统有大量相似任务的线程）中使用。因为对于大规模并发应用，我们其实并不关心哪一个线程被唤醒。 

现在我们使用Guarded blocks创建一个生产者/消费者应用。这类应用需要在两个线程之间共享数据：生产者生产数据，消费者使用数据。两个线程通过共享对象通信。在这里，线程协同工作的关键是：生产者发布数据之前，消费者不能够去读取数据；消费者没有读取旧数据前，生产者不能发布新数据。 

在下面的例子中，数据通过对象共享的一系列文本消息： 

Java代码 

1. public class Drop {  
2.     // Message sent from producer  
3.     // to consumer.  
4.     private String message;  
5.     // True if consumer should wait  
6.     // for producer to send message,  
7.     // false if producer should wait for  
8.     // consumer to retrieve message.  
9.     private boolean empty = true;  
10.   
11.     public synchronized String take() {  
12.         // Wait until message is  
13.         // available.  
14.         while (empty) {  
15.             try {  
16.                 wait();  
17.             } catch (InterruptedException e) {}  
18.         }  
19.         // Toggle status.  
20.         empty = true;  
21.         // Notify producer that  
22.         // status has changed.  
23.         notifyAll();  
24.         return message;  
25.     }  
26.   
27.     public synchronized void put(String message) {  
28.         // Wait until message has  
29.         // been retrieved.  
30.         while (!empty) {  
31.             try {  
32.                 wait();  
33.             } catch (InterruptedException e) {}  
34.         }  
35.         // Toggle status.  
36.         empty = false;  
37.         // Store message.  
38.         this.message = message;  
39.         // Notify consumer that status  
40.         // has changed.  
41.         notifyAll();  
42.     }  
43. }  

是生产者线程，发送一组消息，字符串DONE表示所有消息都已经发送完成。为了模拟现实情况，生产者线程还会在消息发送时随机的暂停。 

Java代码 

1. import java.util.Random;  
2.   
3. public class Producer implements Runnable {  
4.     private Drop drop;  
5.   
6.     public Producer(Drop drop) {  
7.         this.drop = drop;  
8.     }  
9.   
10.     public void run() {  
11.         String importantInfo[] = {  
12.             "Mares eat oats",  
13.             "Does eat oats",  
14.             "Little lambs eat ivy",  
15.             "A kid will eat ivy too"  
16.         };  
17.         Random random = new Random();  
18.   
19.         for (int i = 0;  
20.              i &lt; importantInfo.length;  
21.              i++) {  
22.             drop.put(importantInfo[i]);  
23.             try {  
24.                 Thread.sleep(random.nextInt(5000));  
25.             } catch (InterruptedException e) {}  
26.         }  
27.         drop.put("DONE");  
28.     }  
29. }  

是消费者线程，读取消息并打印出来，直到读取到字符串DONE为止。消费者线程在消息读取时也会随机的暂停。 

Java代码 

1. import java.util.Random;  
2.   
3. public class Consumer implements Runnable {  
4.     private Drop drop;  
5.   
6.     public Consumer(Drop drop) {  
7.         this.drop = drop;  
8.     }  
9.   
10.     public void run() {  
11.         Random random = new Random();  
12.         for (String message = drop.take();  
13.              ! message.equals("DONE");  
14.              message = drop.take()) {  
15.             System.out.format("MESSAGE RECEIVED: %s%n", message);  
16.             try {  
17.                 Thread.sleep(random.nextInt(5000));  
18.             } catch (InterruptedException e) {}  
19.         }  
20.     }  
21. }  

是主线程，它启动生产者线程和消费者线程。 

Java代码 

1. public class ProducerConsumerExample {  
2.     public static void main(String[] args) {  
3.         Drop drop = new Drop();  
4.         (new Thread(new Producer(drop))).start();  
5.         (new Thread(new Consumer(drop))).start();  
6.     }  
7. }  

注意：Drop类是用来演示Guarded Blocks如何工作的。为了避免重新发明轮子，当你尝试创建自己的共享数据对象时，请查看中已有的数据结构。如需更多信息，请参考。 

不可变对象

（本部分，，译者：Greenster，校对：郑旭东） 
一个对象如果在创建后不能被修改，那么就称为不可变对象。在并发编程中，一种被普遍认可的原则就是：尽可能的使用不可变对象来创建简单、可靠的代码。 

在并发编程中，不可变对象特别有用。由于创建后不能被修改，所以不会出现由于线程干扰产生的错误或是内存一致性错误。 

但是程序员们通常并不热衷于使用不可变对象，因为他们担心每次创建新对象的开销。实际上这种开销常常被过分高估，而且使用不可变对象所带来的一些效率提升也抵消了这种开销。例如：使用不可变对象降低了垃圾回收所产生的额外开销，也减少了用来确保使用可变对象不出现并发错误的一些额外代码。 

接下来看一个可变对象的类，然后转化为一个不可变对象的类。通过这个例子说明转化的原则以及使用不可变对象的好处。 

一个同步类的例子 

是表示颜色的类，每一个对象代表一种颜色，使用三个整形数表示颜色的三基色，字符串表示颜色名称。 

Java代码 

1. public class SynchronizedRGB {  
2.   
3.     // Values must be between 0 and 255.  
4.     private int red;  
5.     private int green;  
6.     private int blue;  
7.     private String name;  
8.   
9.     private void check(int red,  
10.                        int green,  
11.                        int blue) {  
12.         if (red < 0 || red > 255  
13.          &nb