首页 > 编程笔记

Java并发编程轻量级入门教程

在开始讲解 Java 并发编程之前，我们首先需要知道什么是并发，以及并发和并行的区别。

1. 并发 VS 并行

并发（Concurrency）指的是在一个重叠的时间段内执行多个任务。即一个任务可以在前一个任务未完成时开始执行，CPU 会对每个任务分配时间片并切换上下文，但同一时刻依然最多只有一个任务在执行。

并行（Parallelism）指的是在同一时刻执行多个任务。与并发任务在同一个处理器内核或同一个处理器上执行不同，并行任务是在不同的处理器内核或者不同的处理器上执行的。

下图展示了并发与并行在处理任务上的不同：

并发与并行的区别

可以看到，在该图中有两个处理器内核（Core 1 和 Core 2）和两个任务（Task 1 与 Task 2）。并发执行的话，是在一个内核上将两个任务按时间交替切换执行；而并行执行的话，是在两个不同的内核上将两个任务同时分别独立执行。

更通俗一点，假如一个人是一个处理器内核的话，并发与并行做的事情可以用一句话来比喻：一个人一边吃饭一边看书是并发，多个人同时吃饭是并行。

为什么要使用并发呢？因为并发可以带来诸多的好处，包括：

1) 并发可以更充分的利用处理器内核

比如一个任务在等待 IO 的时候，处理器内核是闲置的，这时完全可以启动另一个任务做一些其它的事情。

2) 并发可以更公平的获取执行权

比如一个 Web 服务，假设请求都是顺序处理的话，只有等上一个用户请求处理完成了，才能处理下一个请求。那上一个用户请求非常耗时的话，后面的用户请求会长时间得不到处理。如果采用并发，直观感觉上，所有的用户请求都在同时处理，各个请求任务得到更公平的执行权，用户体验得到极大的改善。

不过，凡事有利必有弊，并发也会带来诸多的问题，包括：

1) 共享数据访问控制让编码变得复杂

并发任务会涉及同一块内存区域的访问问题。比如一个任务在对一个内存位置进行读的时候，另一个任务正在对这个位置进行写，那这个任务读到的值应该是另一个任务写之前的旧值，还是写之后的新值？

还有，两个任务同时对一个内存位置进行写的时候，写进去的应当是哪个任务的值？

这都是问题。所以需要复杂的编码来做控制。

2) CPU 上下文切换带来新的开销

CPU 通过对并发任务分配时间片来让各个任务得以执行，而切换任务的时候会带来上下文切换。即将一个任务切换到下一个任务的时候，CPU 会将当前任务的状态保存下来，再去加载下一个任务的状态，这就是一次上下文切换，而这个切换带来的开销并不小。

了解了并发以后，接着就有一个问题：那怎么来实现并发呢？这里，就不得不介绍线程的概念，介绍线程又不得不先介绍进程。

2. 进程和线程

进程（Process）是一个执行的程序，一个进程由多个线程（Thread）组成，线程是轻量级的进程，线程无法脱离进程单独存在。

进程是资源分配的最小单位，进程间相互独立，不共享数据；线程是 CPU 调度的最小单位（即操作系统分配处理器时间的基本单元），线程间共享进程的数据。

所以，做个比喻：进程就像火车，线程就像车厢。线程无法脱离进程单独运行，就像车厢无法脱离火车单独行进；进程之间相互独立不共享数据而线程之间共享进程的数据，就像不同火车间相互独立不能跨火车共享餐车而同一火车内车厢间可以轻松穿过并共享餐车。

Java 里边的并发编程其实就是多线程编程。从 Java 应用程序的角度来看，入口 Main 方法启动的就是一个 main 线程，我们可以在 main 线程创建其它的线程，多个线程一起做一些事情，就是并发编程。

基础概念就介绍到这里，下面就看一下 Java 里边如何使用多线程吧。

3. Java 多线程编程

在 Java 中，创建线程任务有三种方法，分别是：

1) 实现 Runnable 接口

Java 中最通用的描述线程任务的方法是实现 Runnable 接口并重写其 run 方法。而线程的启动则需要将任务对象传入 Thread 对象并调用其 start 方法来实现。

如下为使用该方法描述任务并启动线程的示例程序： 
public class HelloRunnable implements Runnable {

    public static void main(String[] args) {
        new Thread(new HelloRunnable()).start();
    }

    @Override
    public void run() {
        System.out.println("HelloWorld from a thread!");
    }

}
如上代码中，HelloRunnable 类实现了 Runnable 接口，并重写了其 run 方法。在 main 方法新建 Thread 对象，并将 HelloRunnable 对象作为参数传入，最后调用 Thread 对象的 start 方法来启动线程。

2) 继承 Thread 类

为了方便线程的使用，Thread 类本身实现了 Runnable 接口，所以继承 Thread 类并重写其 run 方法也是一种描述任务的方法。而线程的启动则变为直接调用对象的 start 方法即可。

如下为使用该方法描述任务并启动线程的示例程序： 
public class HelloThread extends Thread {

    public static void main(String[] args) {
        new HelloThread().start();
    }

    @Override
    public void run() {
        System.out.println("HelloWorld from a thread!");
    }

}
如上代码中，HelloThread 类继承了 Thread 类，并重写了其 run 方法。在 main 方法直接新建 HelloThread 对象并调用其父类 start 方法即可启动线程。

3) 实现 Callable 接口

前两种方法，任务处理完均无法生成返回值。而实现 Callable 接口这种方法就是专为生成返回值设计的一种任务创建方法。

使用该方法描述任务时，需要实现 Callable 接口并重写其 call 方法，而任务的启动同样需要使用 Thread 来实现，而为了获取执行结果，中间需要借用一下 FutureTask 对象，等待结果返回的过程是阻塞的。

如下为使用该方法描述任务并启动线程的示例程序： 
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.FutureTask;

public class HelloCallable implements Callable<String> {

    public static void main(String[] args) throws ExecutionException, InterruptedException {
        FutureTask<String> task = new FutureTask<>(new HelloCallable());
        new Thread(task).start();

        String result = task.get();
        System.out.println(result);
    }

    @Override
    public String call() throws Exception {
        System.out.println("HelloWorld from a thread!");
        return "OK";
    }

}
如上代码中，HelloCallable 类实现了 Callable 接口，并实现了其 call 方法。

代码分析。在 main 方法新建 FutureTask 对象，并将 HelloCallable 对象作为参数传入；然后新建 Thread 对象，将 FutureTask 对象作为参数传入；最后调用 Thread 对象的 start 方法来启动线程。

4. 几个线程控制相关的 Java 方法

这里介绍几个常用的与 Java 多线程编程相关的方法，包括：

1) yield() 方法

Thread 的类方法，表示当前线程的主要任务已经完成，告诉线程调度器，可以让渡 CPU 给其它的线程使用一会了。

如下为使用 Thread.yield 的一个示例程序： 
public class HelloYield implements Runnable {

    public static void main(String[] args) {
        // 启动两个线程
        for (int i = 0; i < 2; i++) {
            new Thread(new HelloYield()).start();
        }
    }

    @Override
    public void run() {
        for (int i = 0; i < 5; i++) {
            System.out.println(Thread.currentThread().getName() + "#" + i);

            // 每循环打印一次，即让渡 CPU 给别的线程
            Thread.yield();
        }
    }

}
该示例程序的运行结果如下：

Thread-0#0
Thread-1#0
Thread-0#1
Thread-1#1
Thread-0#2
Thread-1#2
Thread-1#3
Thread-0#3
Thread-0#4
Thread-1#4

该示例代码中，HelloYield 是一个实现了 Runnable 接口的线程任务，该任务是一个迭代次数为 5 的循环，每次循环会打印线程名和当前循环编号，并调用一次 Thread 的 yield() 方法。我们在 main 线程启动了两个 HelloYield 线程任务。

从运行结果可以看到，两个 HelloYield 线程任务交替打印信息直至执行完毕。

2) sleep() 方法

Thread 的类方法，表示当前线程要休眠一段指定的时间，这段时间不占用 CPU 处理时间，从而别的线程可能会抢占到执行权。休眠的过程中可能被别的线程打断，从而抛出 InterruptedException。

如下为使用 Thread.sleep 的一个示例程序： 
import java.util.concurrent.TimeUnit;

public class HelloSleep implements Runnable {

    public static void main(String[] args) {
        // 启动两个线程
        for (int i = 0; i < 2; i++) {
            new Thread(new HelloSleep()).start();
        }
    }

    @Override
    public void run() {
        for (int i = 0; i < 5; i++) {
            System.out.println(Thread.currentThread().getName() + "#" + i);

            // 休眠 100 毫秒
            try {
                TimeUnit.MILLISECONDS.sleep(100);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

}
该示例程序的运行结果如下：

Thread-0#0
Thread-1#0
Thread-0#1
Thread-1#1
Thread-1#2
Thread-0#2
Thread-1#3
Thread-0#3
Thread-1#4
Thread-0#4

该示例代码中，HelloSleep 是一个实现了 Runnable 接口的线程任务，该任务是一个迭代次数为 5 的循环，每次循环会打印线程名和当前循环编号，然后休眠 100 毫秒。我们在 main 线程启动了两个 HelloSleep 线程任务。

从运行结果可以看到，两个 HelloSleep 线程任务交替打印信息直至执行完毕。

3) join() 方法

Thread 的实例方法，一个线程可以调用另一个线程的 join 方法，表示调用 join 方法的这个线程会被阻塞执行，一直等待被调用 join 方法的另一个线程执行完毕后再继续执行当前线程。

如下为使用 Thread.join 的一个示例程序： 
import java.util.concurrent.TimeUnit;

public class HelloJoin implements Runnable {

    public static void main(String[] args) {
        // 启动线程 t
        Thread t = new Thread(new HelloJoin());
        t.start();

        // 等待 t 线程执行完毕
        try {
            t.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        // 打印 main 线程信息
        System.out.println("Hello from main Thread!");
    }

    @Override
    public void run() {
        for (int i = 0; i < 5; i++) {
            System.out.println(Thread.currentThread().getName() + "#" + i);

            // 休眠 100 毫秒
            try {
                TimeUnit.MILLISECONDS.sleep(100);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

}
该示例程序的运行结果如下：

Thread-0#0
Thread-0#1
Thread-0#2
Thread-0#3
Thread-0#4
Hello from main Thread!

该示例代码中，HelloJoin 是一个实现了 Runnable 接口的线程任务，该任务是一个迭代次数为 5 的循环，每次循环会打印线程名和当前循环编号，然后休眠 100 毫秒。我们在 main 线程将 HelloJoin 线程任务启动后，接着调用其 join() 方法，然后 main 线程打印一句 Hello 信息。

从运行结果可以看到，该子线程运行完毕后才打印了 main 线程的 Hello 信息。

4) interrupt() 方法

Thread 的实例方法，可以使用 interrupt 来中断一个线程，但被中断线程并未消亡，只是收到一个提醒。

如下为使用 Thread.interrupt() 的一个示例程序： 
import java.util.concurrent.TimeUnit;

public class HelloInterrupt implements Runnable {

    public static void main(String[] args) {
        // 启动线程 t
        Thread t = new Thread(new HelloInterrupt());
        t.start();

        // 打断线程 t
        t.interrupt();
    }

    @Override
    public void run() {
        for (int i = 0; i < 5; i++) {
            System.out.println(Thread.currentThread().getName() + "#" + i);

            // 休眠 100 毫秒
            try {
                TimeUnit.MILLISECONDS.sleep(100);
            } catch (InterruptedException e) {
                System.out.println("Interrupted by other Thread!");
            }
        }
    }

}
该示例程序的运行结果如下：

Thread-0#0
Interrupted by other Thread!
Thread-0#1
Thread-0#2
Thread-0#3
Thread-0#4

该示例代码中，HelloInterrupt 是一个实现了 Runnable 接口的线程任务，该任务是一个迭代次数为 5 的循环，每次循环会打印线程名和当前循环编号，然后休眠 100 毫秒；休眠中若捕获到 InterruptedException，则打印一句被中断的信息。我们在 main 线程将 HelloInterrupt 线程任务启动后，接着调用其 interrupt() 方法将其打断。

从运行结果可以看到，该子线程运行过程中捕获到了 InterruptedException 并打印了被中断信息，但未中止，直至任务完毕才退出执行。

推荐阅读