Java多线程基础学习

作者: SmartSean | 来源:发表于2017-05-09 16:33 被阅读1031次

写在前面的话：

这篇博客是我从这里“转载”的，为什么转载两个字加“”呢？因为这绝不是简单的复制粘贴，我花了五六个小时对其中每一行的代码都有认真的练习，对其中的一些小错误进行调整，并且重新排版，希望通过本篇博客可以让自己对 Java 多线程有更好的理解，同时也希望能够帮助正在学习多线程的你。

此文只能说是 Java 多线程的一个入门，其实Java里头线程完全可以写一本书了，但是如果最基本的你都没掌握好，又怎么能更上一个台阶呢？如果你觉得此文很简单，那推荐你看看Java并发包的的线程池（Java 并发编程与技术内幕:线程池深入理解），或者看这个专栏：Java 并发编程与技术内幕。你将会对 Java 里头的高并发场景下的线程有更加深刻的理解

本文主要讲了 Java 中多线程的使用方法、线程同步、线程数据传递、线程状态及相应的一些线程函数用法、概述等。在这之前，首先让我们来了解下在操作系统中进程和线程的区别：

进程：每个进程都有独立的代码和数据空间（进程上下文），进程间的切换会有较大的开销，一个进程包含1--n个线程。（进程是资源分配的最小单位）

线程：同一类线程共享代码和数据空间，每个线程有独立的运行栈和程序计数器(PC)，线程切换开销小。（线程是 cpu 调度的最小单位）

线程和进程一样分为五个阶段：创建、就绪、运行、阻塞、终止。
多进程是指操作系统能同时运行多个任务（程序）。
多线程是指在同一程序中有多个顺序流在执行。

在 Java 中要想实现多线程，有两种手段：

一种是继承 Thread 类；
一种是实现 Runnable 接口.

其实准确来讲，应该有三种，还有一种是实现 Callable 接口，并与 Future、线程池结合使用，此文不讲这个，有兴趣看这里 Java 并发编程与技术内幕：Callable、Future、FutureTask、CompletionService

一、扩展java.lang.Thread类

这里继承 Thread 类的方法是比较常用的一种，如果说你只是想重新开启一条线程。没有什么其它特殊的要求，那么可以使用 Thread ，（笔者推荐使用 Runnable ，后头会说明为什么）。下面来看一个简单的实例：

/**
 * Created by Sean on 2017/5/9.
 */
class Thread1 extends Thread {
    private String threadName; // 用于标示不同的线程

    public Thread1(String threadName) {
        this.threadName = threadName;
    }

    @Override
    public void run() {
        super.run();
        for (int i = 0; i < 5; i++) {
            System.out.println(threadName + "运行，此时的 i = " + i);
            try {
                sleep((int) Math.random() * 10);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

public class Main {

    public static void main(String[] args) {
        System.out.println("Hello World!");
        Thread1 thread1 = new Thread1("我是A线程");
        Thread1 thread2 = new Thread1("我是B线程");
        thread1.start();
        thread2.start();
    }
}

运行结果：

运行结果

说明：

程序启动运行 main 时候， java 虚拟机启动一个进程，主线程 main 在
main() 调用时候被创建。随着调用 Thread1 的两个对象的 start 方法，另外两个线程也启动了，这样，整个应用就在多线程下运行。

注意：

start() 方法的调用后并不是立即执行多线程代码，而是使得该线程变为可运行态（Runnable），什么时候运行是由操作系统决定的。

从程序运行的结果可以发现，多线程程序是乱序执行。因此，只有乱序执行的代码才有必要设计为多线程。

Thread.sleep() 方法调用目的是不让当前线程独自霸占该进程所获取的
CPU 资源，以留出一定时间给其他线程执行的机会。

实际上所有的多线程代码执行顺序都是不确定的，每次执行的结果都是随机的。

此外 start() 方法重复调用的话，会出现java.lang.IllegalThreadStateException异常。

比如把 Main 类代码改成下面：

public class Main {

    public static void main(String[] args) {
        Thread1 thread1 = new Thread1("我是A线程");
        thread1.start();
        thread1.start();
    }
}

结果如下：

重复调用 start() 异常

二、实现 java.lang.Runnable 接口

采用 Runnable 也是非常常见的一种，我们只需要重写 run() 即可。下面也来看个实例。

使用继承 Thread 实现共享的错误示范

/**
 * Created by Sean on 2017/5/9.
 */


class Thread2 implements Runnable {

    private String threadName;

    public Thread2(String threadName) {
        this.threadName = threadName;
    }

    @Override
    public void run() {
        for (int i = 0; i < 5; i++) {
            System.out.println(threadName + "运行，此时的 i = " + i);
            try {
                Thread.sleep((int) Math.random() * 10);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

public class Main2 {
    public static void main(String[] args) {
        new Thread(new Thread2("我是在A线程中")).start();
        new Thread(new Thread2("我是在B线程中")).start();
    }
}

结果：

运行结果

说明：

Thread2 类是通过实现 Runnable 接口，使该类有了多线程类的特征， run() 方法是多线程程序的一个约定，所有的多线程代码都在 run() 方法里面，事实上， Thread 类也是实现了 Runnable 接口的类。

在启动实现了 Runnable 接口的类的多线程的时候，需要先通过 Thread 类的构造方法 Thread(Runanable target) 构造出 Thread 对象，然后调用 Thread 对象的 start() 方法来开启线程，运行 run() 方法里面的多线程代码（这个run() 方法不需要开发者手动调用，会在操作系统分给该线程时间片的时候自动运行）

实际上所有的多线程代码都是通过运行 Thread 的 start() 方法来运行的。因此，不管是扩展 Thread 类还是实现 Runnable 接口来实现多线程，最终还是通过 Thread 的对象的 API 来控制线程的，熟悉 Thread 类的 API 是进行多线程编程的基础。

三、Thread和Runnable的区别

如果一个类继承 Thread，则不适合资源共享。但是如果实现了 Runable 接口的话，则很容易的实现资源共享。

上面这句话是原博客里面给出的，我认为是有瑕疵的。

以卖票程序为例，下面来说明为什么这样说：

使用继承 Thread 的方式共享的错误示例

/**
 * Created by Sean on 2017/5/9.
 */
class Thread3 extends Thread {
    private String threadName;
    private int ticket = 5;

    public Thread3(String threadName) {
        this.threadName = threadName;
    }

    @Override
    public void run() {
        for (int i = 0; i < 5; i++) {
            synchronized (this) {
                if (ticket > 0){
                    System.out.println(threadName + "运行，此时的 i = " + i+" 剩余票数" + this.ticket--);
                }
            }
            try {
                sleep(500);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

public class Main3 {
    public static void main(String[] args){
        Thread3 thread1 = new Thread3("我是在A线程中");
        Thread3 thread2 = new Thread3("我是在B线程中");
        Thread3 thread3 = new Thread3("我是在C线程中");
        thread1.start();
        thread2.start();
        thread3.start();
    }
}

结果：

运行结果

从上面的结果可以看到，开启了三个线程，每个线程都卖了5张票，这明显是不合理的，接下来看看用 Runnable 来实现共享 5 张票的例子

使用实现 Runnable 实现共享票数

import static java.lang.Thread.currentThread;
import static java.lang.Thread.sleep;

/**
 * Created by Sean on 2017/5/9.
 */
class Thread4 implements Runnable {

    private int ticket = 5;

    @Override
    public void run() {
        for (int i = 0; i < 5; i++) {
            synchronized (this) {
                if (ticket > 0) {
                    System.out.println(currentThread().getName() + "运行，此时的 i = " + i + " 剩余票数" + this.ticket--);
                }
            }
            try {
                sleep(400);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

public class Main4 {
    public static void main(String[] args) {
        Thread4 thread1 = new Thread4();
        new Thread(thread1, "我是在A线程中").start();
        new Thread(thread1, "我是在B线程中").start();
        new Thread(thread1, "我是在C线程中").start();
    }
}

运行结果：

运行结果

可以看到，我们用实现 Runnable 接口的方式实现了资源的共享。

那么我们使用继承 Thread 的方式就真的没法实现资源共享吗？

答案是 NO！

往下看。

使用继承 Thread 的方式共享的正确示例

我们先看下面的代码：

/**
 * Created by Sean on 2017/5/9.
 */
class Thread5 extends Thread {

    private int ticket = 5;

    @Override
    public void run() {
        for (int i = 0; i < 5; i++) {
            synchronized (this) {
                if (ticket > 0) {
                    System.out.println(currentThread().getName() + "运行，此时的 i = " + i + " 剩余票数" + this.ticket--);
                }
            }
            try {
                sleep(500);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

public class Main5 {
    public static void main(String[] args) {
        Thread5 thread1 = new Thread5();
        new Thread(thread1, "我是在A线程中").start();
        new Thread(thread1, "我是在B线程中").start();
        new Thread(thread1, "我是在C线程中").start();
    }
}

运行结果：

运行结果

可以看到，虽然我们使用了继承 Thread 的方式来实现线程类，最后我们也同样实现了多线程中资源的共享。

从而可以判断，原博客的话是有一定错误的。

下面看一下总结：

实现 Runnable 接口比继承 Thread 类所具有的优势：

可以避免java中的单继承的限制
线程池只能放入实现 Runable 或 callable 类线程，不能直接放入继承
Thread 的类

两者都有的：

适合多个相同的程序代码的线程去处理同一个资源
增加程序的健壮性，代码可以被多个线程共享，代码和数据独立

提醒一下大家： main() 方法其实也是一个线程，在 java 中所有的线程都是同时启动的，至于什么时候启动，哪个线程先执行，完全是看哪个线程先从 cpu 哪里获取时间片资源。

此外：在 java 中，每次程序运行至少启动两个线程，一个是 main 线程，一个是垃圾回收线程。因为每当使用 java 命令执行一个类的时候，实际上都会启动一个 JVM ，每一个 JVM 实际就是在操作系统中启动了一个进程。

四、线程状态转换

下面的这个图非常重要！你如果看懂了这个图，那么对于多线程的理解将会更加深刻！

线程状态转换图

学过操作系统的同学应该看起来很容易的，毕竟当初考试的时候这一块是个重点，没少复习这一块。

新建状态（New）：新创建了一个线程对象
就绪状态（Runnable）：线程对象创建后，其他线程调用了该对象的 start() 方法，该状态的线程位于可运行的线程池中，变为可运行状态，这个时候，只要获取了 cpu 的执行权，就可以运行，进入运行状态。
运行状态（Running）：就绪状态的线程从 cpu 获得了执行权之后，便可进入此状态，执行 run() 方法里面的代码。
阻塞状态（Blocked）：阻塞状态是线程因为某种原因失去了 cpu 的使用权，暂时停止运行，一直等到线程进入就绪状态，才有机会转到运行状态，阻塞一般分为下面三种：
- 等待阻塞：运行的线程执行了 wait() 方法， JVM 会把该线程放入线程等待池中，（wait() 会释放持有的锁）
- 同步阻塞：运行的线程在获取对象的同步锁时，如果该同步锁被其他线程占用，这时此线程是无法运行的，那么 JVM 就会把该线程放入锁池中，导致阻塞
- 其他阻塞：运行的线程执行 sleep() 或者 join() 方法，或者发出了 I/O 请求，JVM 会把该线程置为阻塞状态，当 sleep() 状态超时、join() 等待线程终止或者超时、或者 I/O 处理完毕时，线程会重新进入就绪状态，（注意：sleep() 是不会释放本身持有的锁的）
死亡状态（Dead）：线程执行完了之后或者因为程序异常退出了 run() 方法，结束该线程的生命周期。

五、线程调度

1. 调整线程优先级

Java 线程有优先级，优先级高的线程会获得较多的运行机会，Java 线程的优先级用整数表示，取值范围是 1~10 ，Thread 类有以下三个静态常量：

static int MAX_PRIORITY      线程可以具有的最高优先级，取值为10。  
static int MIN_PRIORITY       线程可以具有的最低优先级，取值为1。  
static int NORM_PRIORITY   分配给线程的默认优先级，取值为5。

Thread 类的 setPriority() 和 getPriority() 分别用于设置和获取线程的优先级。

每个线程都有默认的优先级。主线程的默认优先级为Thread.NORM_PRIORITY。
线程的优先级有继承关系，比如A线程中创建了B线程，那么B将和A具有相同的优先级。

JVM提供了10个线程优先级，但与常见的操作系统都不能很好的映射。如果希望程序能移植到各个操作系统中，应该仅仅使用Thread类有以下三个静态常量作为优先级，这样能保证同样的优先级采用了同样的调度方式。

2. 线程睡眠

Thread.sleep(long millis) 方法，使线程转到阻塞状态。millis 参数设定睡眠的时间，以毫秒为单位。当睡眠结束后，就转为就绪（Runnable）状态。sleep() 平台移植性好。

3. 线程等待

Object 类中的 wait() 方法，导致当前的线程等待，直到其他线程调用此对象的 notify() 方法或 notifyAll() 唤醒方法。这个两个唤醒方法也是 Object
类中的方法，行为等价于调用 wait(0) 一样。

4. 线程让步

Thread.yield()方法，暂停当前正在执行的线程对象，把执行机会让给相同或者更高优先级的线程。

5. 线程加入

join() 方法，等待其他线程终止，在当前线程中调用一个线程的 join() 方法，则当前线程转为阻塞状态，回到另一个线程结束，当前线程再由阻塞状态变为就绪状态，等待 cpu 的宠幸。

6. 线程唤醒

Object 类中的 notify() 方法，唤醒在此对象监视器上等待的单个线程，如果所有线程都在此对象上等待，则会选择唤醒其中一个线程，选择是任意的，并在对实现做出决定时发生，线程通过调用其中一个 wait() 方法，在对象的监视器上等待，直到当前的线程放弃此对象上的锁定，才能继续执行被唤醒的线程，被唤醒的线程将以常规方式与在该对象上主动同步的其他所有线程进行竞争。

例如：唤醒的线程在作为锁定此对象的下一个线程方面没有可靠的特权或者劣势，

类似的方法还有 notifyAll() ，唤醒再次监视器上等待的所有线程，

注意： Thread 中 suspend() 和 resume() 两个方法已经在 JDK 1.5 中废除，此处不做介绍，因为有死锁倾向。

六、常用函数说明

1. `sleep(long millis)`: 在指定的毫秒数内让当前正在执行的线程休眠（暂停执行）

2. `join()` 指等待t线程终止。

使用方式

Thread6 thread1 = new Thread6();
thread1.start();
thread1.join();

为什么要用join()方法

很多情况下，主线程生成并启动了子线程，如果子线程需要大量的耗时运算，主线程往往将于子线程结束之前结束，但是如果主线程处理完了其他事务后，需要用到子线程返回的结果，也就是需要主线程需要在子线程结束后再结束，这时候就要用到 join() 方法。

先看下不加 join() 的代码：

/**
 * Created by Sean on 2017/5/9.
 */
class Thread6 extends Thread {

    @Override
    public void run() {
        super.run();
        System.out.println(Thread.currentThread().getName() + "运行开始!");
        for (int i = 0; i < 5; i++) {
            System.out.println(currentThread().getName() + "======>" + i);
            try {
                sleep(500);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        System.out.println(Thread.currentThread().getName() + "运行结束!");
    }
}

public class Main6 {
    public static void main(String[] args) throws InterruptedException {
        System.out.println(Thread.currentThread().getName() + "线程运行开始!");
        Thread6 thread1 = new Thread6();
        Thread6 thread2 = new Thread6();
        thread1.setName("线程A");
        thread2.setName("线程B");
        thread1.start();
        thread2.start();
        System.out.println("这时thread1 和 thread2 都执行完毕之后才能执行主线程打印此句话因为两个子线程都被主线程调用了join() 方法");
        System.out.println(Thread.currentThread().getName() + "线程运行结束!");
    }
}

结果：

运行结果

从结果中可以看到我们打印的 main 线程运行结束之后，两个子线程才开始执行，这和上面说的是对照的，

下面演示下等待两个子线程结束之后再结束主线程：

/**
 * Created by Sean on 2017/5/9.
 */
class Thread6 extends Thread {

    @Override
    public void run() {
        super.run();
        System.out.println(Thread.currentThread().getName() + "运行开始!");
        for (int i = 0; i < 5; i++) {
            System.out.println(currentThread().getName() + "======>" + i);
            try {
                sleep(500);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        System.out.println(Thread.currentThread().getName() + "运行结束!");
    }
}

public class Main6 {
    public static void main(String[] args) throws InterruptedException {
        System.out.println(Thread.currentThread().getName() + "线程运行开始!");
        Thread6 thread1 = new Thread6();
        Thread6 thread2 = new Thread6();
        thread1.setName("线程A");
        thread2.setName("线程B");
        thread1.start();
        try {
            thread1.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        thread2.start();
        try {
            thread2.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("这时thread1 和 thread2 都执行完毕之后才能执行主线程打印此句话因为两个子线程都被主线程调用了join() 方法");
        System.out.println(Thread.currentThread().getName() + "线程运行结束!");
    }
}

运行结果：

运行结果

这个时候不论执行多少遍，都是主线程等待子线程结束后才结束。

如果主线程的执行需要依赖于子线程中的完整数据的时候，这种方法就可以很好的确保两个线程的同步性。

3. yield():暂停当前正在执行的线程对象，并执行其他线程。

注意：yield() 应该做的是让当前运行线程回到可运行状态（就绪状态），以允许具有相同优先级的其他线程获得运行机会。因此，使用 yield() 的目的是让相同优先级的线程之间能适当的轮转执行。但是，实际中无法保证 yield() 达到让步目的，因为让步的线程还有可能被线程调度程序再次选中。

结论：yield() 从未导致线程转到等待/睡眠/阻塞状态。在大多数情况下，yield() 将导致线程从运行状态转到可运行状态（就绪状态），但有可能没有效果。可看上面的图。

看下面的例子：

/**
 * yield()的用法
 * Created by Sean on 2017/5/9.
 */
class Thread7 extends Thread {

    @Override
    public void run() {
        for (int i = 1; i <= 50; i++) {
            System.out.println("" + this.getName() + "-----" + i);
            // 当i为30时，该线程就会把CPU时间让掉，让其他或者自己的线程执行（也就是谁先抢到谁执行）
            if (i == 30) {
                this.yield();
            }
        }
    }
}

public class Main7 {
    public static void main(String[] args) {
        Thread7 thread1 = new Thread7();
        Thread7 thread2 = new Thread7();
        thread1.setName("A线程");
        thread2.setName("B线程");
        thread1.start();
        thread2.start();
    }
}

运行结果：

第一种情况：A线程当执行到30时会CPU时间让掉，这时A线程抢到 CPU 的时间片执行。
第二种情况：B线程当执行到30时会CPU时间让掉，这时A线程抢到 CPU 的时间片执行。
第二种情况：从一开始就交替执行，当到30的时候进行一次让步。

sleep()和yield()的区别

sleep() 使当前线程进入停滞状态，所以执行 sleep() 的线程在指定的时间内肯定不会被执行
yield() 只是使当前线程重新回到可执行状态，所以执行 yield() 的线程有可能在进入到可执行状态后马上又被执行。

sleep 方法使当前运行中的线程睡眼一段时间，进入不可运行状态，这段时间的长短是由程序设定的，yield 方法使当前线程让出 CPU 占有权，但让出的时间是不可设定的。实际上，yield() 方法对应了如下操作：先检测当前是否有相同优先级的线程处于同可运行状态，如有，则把 CPU 的占有权交给此线程，否则，继续运行原来的线程。所以yield()方法称为“退让”，它把运行机会让给了同等优先级的其他线程

另外，sleep 方法允许较低优先级的线程获得运行机会，但 yield() 方法执行时，当前线程仍处在可运行状态，所以，不可能让出较低优先级的线程些时获得 CPU 占有权。在一个运行系统中，如果较高优先级的线程没有调用 sleep 方法，又没有受到 I\O 阻塞，那么，较低优先级线程只能等待所有较高优先级的线程运行结束，才有机会运行。

4. setPriority(): 更改线程的优先级。

MIN_PRIORITY = 1
NORM_PRIORITY = 5
MAX_PRIORITY = 10
用法：
Thread4 t1 = new Thread4("t1");
Thread4 t2 = new Thread4("t2");
t1.setPriority(Thread.MAX_PRIORITY);
t2.setPriority(Thread.MIN_PRIORITY);

5. interrupt()

不要以为它是中断某个线程！它只是线线程发送一个中断信号，让线程在无限等待时（如死锁时）能抛出抛出，从而结束线程，但是如果你吃掉了这个异常，那么这个线程还是不会中断的！

6. wait() 暂停线程，释放 cpu 控制权，同时释放对象锁的控制

Obj.wait() 与 Obj.notify() 必须要与 synchronized(Obj) 一起使用，也就是
wait 与 notify 是针对已经获取了 Obj 锁进行操作，从语法角度来说就是
Obj.wait()、Obj.notify 必须在 synchronized(Obj){...} 语句块内。从功能上来说 wait 就是说线程在获取对象锁后，主动释放对象锁，同时本线程休眠。直到有其它线程调用对象的notify()唤醒该线程，才能继续获取对象锁，并继续执行。相应的 notify() 就是对对象锁的唤醒操作。但有一点需要注意的是 notify() 调用后，并不是马上就释放对象锁的，而是在相应的 synchronized(){} 语句块执行结束，自动释放锁后， JVM会在wait() 对象锁的线程中随机选取一线程，赋予其对象锁，唤醒线程，继续执行。这样就提供了在线程间同步、唤醒的操作。 Thread.sleep() 与 Object.wait() 二者都可以暂停当前线程，释放 CPU 控制权，主要的区别在于 Object.wait() 在释放 CPU 同时，释放了对象锁的控制。
单单在概念上理解清楚了还不够，需要在实际的例子中进行测试才能更好的理解。对 Object.wait() 、Object.notify() 的应用最经典的例子，应该是三线程打印 ABC 的问题了吧，这是一道比较经典的面试题，题目要求如下：
建立三个线程，A线程打印 10 次 A、B 线程打印 10 次 B、C 线程打印
10 次 C，要求线程同时运行，交替打印 10 次 ABC 。这个问题用 Object
的 wait() ， notify() 就可以很方便的解决。代码如下：

/**
 * wait() 练习
 * Created by Sean on 2017/5/9.
 */
class Thread8 implements Runnable {

    private String name;
    private Object prev;
    private Object self;

    private Thread8(String name, Object prev, Object self) {
        this.name = name;
        this.prev = prev;
        this.self = self;
    }

    @Override
    public void run() {
        int count = 10;
        while (count > 0) {
            synchronized (prev) {   //上一个对象锁，先申请上一个对象的锁，如果上个线程释放对象锁，则获取该对象锁
                synchronized (self) {   // 当前对象锁
                    System.out.print(name + ((count == 1 && name.equals("C")) ? "" : "->"));
                    count--;
                    self.notify(); // 唤醒下一个等待线程
                }
                try {
                    prev.wait();// 释放当前线程
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    }

    public static void main(String[] args) throws InterruptedException {
        Object a = new Object();
        Object b = new Object();
        Object c = new Object();
        Thread8 threadA = new Thread8("A", c, a);//c是上个对象,a是当前对象
        Thread8 threadB = new Thread8("B", a, b);//a是上个对象,b是当前对象
        Thread8 threadC = new Thread8("C", b, c);//b是上个对象,c是当前对象
        new Thread(threadA).start();
        Thread.sleep(100);  //确保按顺序A、B、C执行
        new Thread(threadB).start();
        Thread.sleep(100);  //确保按顺序A、B、C执行
        new Thread(threadC).start();
        Thread.sleep(100);  //确保按顺序A、B、C执行
    }
}

输出结果：

输出结果

先来解释一下其整体思路，从大的方向上来讲，该问题为三线程间的同步唤醒操作，主要的目的就是 ThreadA -> ThreadB -> ThreadC -> ThreadA 循环执行三个线程。为了控制线程执行的顺序，那么就必须要确定唤醒、等待的顺序，所以每一个线程必须同时持有两个对象锁，才能继续执行。一个对象锁是 prev ，就是前一个线程所持有的对象锁。还有一个就是自身对象锁。主要的思想就是，为了控制执行的顺序，必须要先持有 prev 锁，也就前一个线程要释放自身对象锁，再去申请自身对象锁，两者兼备时打印，之后首先调用 self.notify() 释放自身对象锁，唤醒下一个等待线程，再调用 prev.wait() 释放 prev 对象锁，终止当前线程，等待循环结束后再次被唤醒。

通过上面代码可以看到， A、B、C 都被顺序打印了十次，过程是这样的：

打印A：A 线程先运行，A 线程持有 C、A对像锁，因为C对象锁对应上一个打印的线程，A 对象锁对应自己打印的线程。然后在自身对象锁中synchronized (self) { }执行完之后唤醒下一个打印线程，然后在上一个对象锁synchronized (prev) { }中暂停线程、释放 CPU 的控制权，同时释放 C 对象锁的控制权
打印B：拿到线程 A 释放的 A 对像锁，然后获取自身的 B 对象锁，重复上面“打印A”的步骤
打印C：拿到线程 B 释放的 B 对像锁，然后获取自身的 C 对象锁，重复上面“打印A”的步骤
打印A：拿到线程 C 释放的 C 对像锁，然后获取自身的 A 对象锁，重复上面“打印A”的步骤
.
.
.
.
.
这样一直执行到程序结束全部打印完毕。

wait() 和 sleep() 区别

共同点：

他们都是在多线程的环境下，都可以在程序的调用处阻塞指定的毫秒数，并返回。
wait()和sleep()都可以通过interrupt()方法打断线程的暂停状态，从而使线程立刻抛出InterruptedException。

如果线程A希望立即结束线程B，则可以对线程B对应的Thread实例调用interrupt方法。如果此刻线程B正在wait/sleep /join，则线程B会立刻抛出InterruptedException，在catch() {} 中直接return即可安全地结束线程。
需要注意的是，InterruptedException是线程自己从内部抛出的，并不是interrupt()方法抛出的。对某一线程调用 interrupt()时，如果该线程正在执行普通的代码，那么该线程根本就不会抛出InterruptedException。但是，一旦该线程进入到 wait()/sleep()/join()后，就会立刻抛出InterruptedException 。

不同点：

Thread类的方法：sleep(),yield()等
Object的方法：wait()和notify()等
每个对象都有一个锁来控制同步访问。Synchronized关键字可以和对象的锁交互，来实现线程的同步。
sleep方法没有释放锁，而wait方法释放了锁，使得其他线程可以使用同步控制块或者方法。
wait，notify和notifyAll只能在同步控制方法或者同步控制块里面使用，而sleep可以在任何地方使用

所以sleep()和wait()方法的最大区别是：
　　　　sleep()睡眠时，保持对象锁，仍然占有该锁；
　　　　而wait()睡眠时，释放对象锁。
但是wait()和sleep()都可以通过interrupt()方法打断线程的暂停状态，从而使线程立刻抛出InterruptedException（但不建议使用该方法）

sleep() 方法

sleep()使当前线程进入停滞状态（阻塞当前线程），让出CUP的使用、目的是不让当前线程独自霸占该进程所获的CPU资源，以留一定时间给其他线程执行的机会;

sleep()是Thread类的Static(静态)的方法；因此他不能改变对象的机锁，所以当在一个Synchronized块中调用Sleep()方法是，线程虽然休眠了，但是对象的机锁并木有被释放，其他线程无法访问这个对象（即使睡着也持有对象锁）。

在sleep()休眠时间期满后，该线程不一定会立即执行，这是因为其它线程可能正在运行而且没有被调度为放弃执行，除非此线程具有更高的优先级。

wait() 方法

wait()方法是Object类里的方法；当一个线程执行到wait()方法时，它就进入到一个和该对象相关的等待池中，同时失去（释放）了对象的机锁（暂时失去机锁，wait(long timeout)超时时间到后还需要返还对象锁）；其他线程可以访问；

wait()使用notify或者notifyAlll或者指定睡眠时间来唤醒当前等待池中的线程。

wiat()必须放在synchronized block中，否则会在program runtime时扔出”java.lang.IllegalMonitorStateException“异常。

七、常见线程名词解释以及常用方法

1. 名词解释

主线程：JVM 调用程序 main() 所产生的线程。
当前线程：这个是容易混淆的概念。一般指通过 Thread.currentThread() 来获取的进程。
后台线程：指为其他线程提供服务的线程，也称为守护线程。JVM 的垃圾回收线程就是一个后台线程。用户线程和守护线程的区别在于，是否等待主线程依赖于主线程结束而结束
前台线程：是指接受后台线程服务的线程，其实前台后台线程是联系在一起，就像傀儡和幕后操纵者一样的关系。傀儡是前台线程、幕后操纵者是后台线程。由前台线程创建的线程默认也是前台线程。可以通过
isDaemon() 和 setDaemon() 方法来判断和设置一个线程是否为后台线程。

2. 线程类的一些常用方法：

sleep()：强迫一个线程睡眠Ｎ毫秒。
isAlive()：判断一个线程是否存活。
join()：等待线程终止。
activeCount()：程序中活跃的线程数。
enumerate()：枚举程序中的线程。
currentThread()：得到当前线程。
isDaemon()：一个线程是否为守护线程。
setDaemon()：设置一个线程为守护线程。(用户线程和守护线程的区别在于，是否等待主线程依赖于主线程结束而结束)
setName()：为线程设置一个名称。
wait()：强迫一个线程等待。
notify()：通知一个线程继续运行。
setPriority()：设置一个线程的优先级。
getPriority():：获得一个线程的优先级。

八、线程同步

1、synchronized关键字的作用域

是某个对象实例内，synchronized aMethod(){} 可以防止多个线程同时访问这个对象的 synchronized 方法（如果一个对象有多个 synchronized 方法，只要一个线程访问了其中的一个 synchronized 方法，其它线程不能同时访问这个对象中任何一个 synchronized 方法）。这时，不同的对象实例的 synchronized 方法是不相干扰的。也就是说，其它线程照样可以同时访问相同类的另一个对象实例中的 synchronized 方法；
是某个类的范围，synchronized static aStaticMethod{} 防止多个线程同时访问这个类中的 synchronized static 方法。它可以对类的所有对象实例起作用。

2、synchronized关键字实现互斥访问

除了方法前用 synchronized 关键字， synchronized 关键字还可以用于方法中的某个区块中，表示只对这个区块的资源实行互斥访问。用法是: synchronized(this){/*区块*/}，它的作用域是当前对象；

3. 不能继承

synchronized 关键字是不能继承的，也就是说，基类的方法 synchronized f(){}在继承类中并不自动是synchronized f(){}，而是变成了 f(){} 。继承类需要你显式的指定它的某个方法为 synchronized 方法；

4. 用法

Java对多线程的支持与同步机制深受大家的喜爱，似乎看起来使用了synchronized关键字就可以轻松地解决多线程共享数据同步问题。到底如何？――还得对synchronized关键字的作用进行深入了解才可定论。

总的说来，synchronized关键字可以作为函数的修饰符，也可作为函数内的语句，也就是平时说的同步方法和同步语句块。如果再细的分类，synchronized可作用于instance变量、object reference（对象引用）、static函数和class literals(类名称字面常量)身上。

在进一步阐述之前，我们需要明确几点：

无论synchronized关键字加在方法上还是对象上，它取得的锁都是对象，而不是把一段代码或函数当作锁――而且同步方法很可能还会被其他线程的对象访问。
每个对象只有一个锁（lock）与之相关联。
实现同步是要很大的系统开销作为代价的，甚至可能造成死锁，所以尽量避免无谓的同步控制。

接着来讨论synchronized用到不同地方对代码产生的影响：

假设P1、P2是同一个类的不同对象，这个类中定义了以下几种情况的同步块或同步方法，P1、P2就都可以调用它们。

把synchronized当作函数修饰符时

示例代码如下：

Public synchronized void methodAAA()  
{  
      //….  
}

这也就是同步方法，那这时 synchronized 锁定的是哪个对象呢？它锁定的是调用这个同步方法对象。也就是说，当一个对象 P1 在不同的线程中执行这个同步方法时，它们之间会形成互斥，达到同步的效果。但是这个对象所属的 Class 所产生的另一对象 P2 却可以任意调用这个被加了
synchronized 关键字的方法。
上边的示例代码等同于如下代码：

public void methodAAA()  
{  
synchronized (this)      //  (1)  
{  
       //…..  
}  
}

(1)处的this指的是什么呢？它指的就是调用这个方法的对象，如P1。可见同步方法实质是将synchronized作用于object reference。――那个拿到了P1对象锁的线程，才可以调用P1的同步方法，而对P2而言，P1这个锁与它毫不相干，程序也可能在这种情形下摆脱同步机制的控制，造成数据混乱.

2. 同步块

示例代码如下：

    public void method3(SomeObject so) {
        synchronized (so) {
            //…..  
        }
    }

这时，锁就是so这个对象，谁拿到这个锁谁就可以运行它所控制的那段代码。当有一个明确的对象作为锁时，就可以这样写程序，但当没有明确的对象作为锁，只是想让一段代码同步时，可以创建一个特殊的 instance 变量（它得是一个对象）来充当锁：

class Foo implements Runnable {
    private byte[] lock = new byte[0];  // 特殊的instance变量  

    public void methodA() {
        synchronized (lock) { //… }  
        }
//…..  
    }
}

注：零长度的 byte 数组对象创建起来将比任何对象都经济――查看编译后的字节码：生成零长度的 byte[] 对象只需3条操作码，而Object lock = new Object()则需要7行操作码。

3. 将synchronized作用于static 函数

示例代码如下：

class Foo {
    public synchronized static void methodAAA()   // 同步的static 函数
    {
//….
    }

    public void methodBBB() {
        synchronized (Foo.class)   //  class literal(类名称字面常量)
    }
}

代码中的 methodBBB() 方法是把 class literal 作为锁的情况，它和同步的
static 函数产生的效果是一样的，取得的锁很特别，是当前调用这个方法的对象所属的类（Class，而不再是由这个 Class 产生的某个具体对象了）。
记得在《Effective Java》一书中看到过将 Foo.class 和 P1.getClass() 用于作同步锁还不一样，不能用 P1.getClass() 来达到锁这个 Class 的目的。 P1 指的是由 Foo 类产生的对象。
可以推断：如果一个类中定义了一个 synchronized 的 static 函数A，也定义了一个 synchronized 的 instance 函数B，那么这个类的同一对象 Obj 在多线程中分别访问 A 和 B 两个方法时，不会构成同步，因为它们的锁都不一样。 A 方法的锁是 Obj 这个对象，而 B 的锁是 Obj 所属的那个
Class 。

总结

线程同步的目的是为了保护多个线程反问一个资源时对资源的破坏。
线程同步方法是通过锁来实现，每个对象都有切仅有一个锁，这个锁与一个特定的对象关联，线程一旦获取了对象锁，其他访问该对象的线程就无法再访问该对象的其他非同步方法
对于静态同步方法，锁是针对这个类的，锁对象是该类的Class对象。静态和非静态方法的锁互不干预。一个线程获得锁，当在一个同步方法中访问另外对象上的同步方法时，会获取这两个对象锁。
对于同步，要时刻清醒在哪个对象上同步，这是关键。
编写线程安全的类，需要时刻注意对多个线程竞争访问资源的逻辑和安全做出正确的判断，对“原子”操作做出分析，并保证原子操作期间别的线程无法访问竞争资源。
当多个线程等待一个对象锁时，没有获取到锁的线程将发生阻塞。
死锁是线程间相互等待锁锁造成的，在实际中发生的概率非常的小。真让你写个死锁程序，不一定好使，呵呵。但是，一旦程序发生死锁，程序将死掉。

九、线程数据传递

在传统的同步开发模式下，当我们调用一个函数时，通过这个函数的参数将数据传入，并通过这个函数的返回值来返回最终的计算结果。但在多线程的异步开发模式下，数据的传递和返回和同步开发模式有很大的区别。由于线程的运行和结束是不可预料的，因此，在传递和返回数据时就无法象函数一样通过函数参数和 return 语句来返回数据。

1. 通过构造方法传递数据

在创建线程时，必须要建立一个 Thread 类的或其子类的实例。因此，我们不难想到在调用 start 方法之前通过线程类的构造方法将数据传入线程。并将传入的数据使用类变量保存起来，以便线程使用(其实就是在 run 方法中使用)。下面的代码演示了如何通过构造方法来传递数据：

/**
 * Created by Sean on 2017/5/9.
 */
class Thread9 extends Thread {
    private String threadName;

    public Thread9(String threadName) {
        this.threadName = threadName;
    }

    public void run() {
        System.out.println("hello " + threadName);
    }
}

public class Main9 {
    public static void main(String[] args) {
        Thread9 thread = new Thread9("world");
        thread.start();
    }
}

由于这种方法是在创建线程对象的同时传递数据的，因此，在线程运行之前这些数据就就已经到位了，这样就不会造成数据在线程运行后才传入的现象。如果要传递更复杂的数据，可以使用集合、类等数据结构。使用构造方法来传递数据虽然比较安全，但如果要传递的数据比较多时，就会造成很多不便。由于 Java 没有默认参数，要想实现类似默认参数的效果，就得使用重载，这样不但使构造方法本身过于复杂，又会使构造方法在数量上大增。因此，要想避免这种情况，就得通过类方法或类变量来传递数据。

2. 通过变量和方法传递数据

向对象中传入数据一般有两次机会：

第一次机会是在建立对象时通过构造方法将数据传入；
另外一次机会就是在类中定义一系列的 public 的方法或变量（也可称之为字段）。然后在建立完对象后，通过对象实例逐个赋值。下面的代码是对Thread9 类的改版，使用了一个 setThreadName 方法来设置 threadName 变量：

/**
 * Created by Sean on 2017/5/9.
 */
class Thread9 extends Thread {
    private String threadName;

    public Thread9(String threadName) {
        this.threadName = threadName;
    }

    public String getThreadName() {
        return threadName;
    }

    public void setThreadName(String threadName) {
        this.threadName = threadName;
    }

    public void run() {
        System.out.println("hello " + threadName);
    }
}

public class Main9 {
    public static void main(String[] args) {
        Thread9 thread = new Thread9("world");
        thread.start();
    }
}

3. 通过回调函数传递数据

面讨论的两种向线程中传递数据的方法是最常用的。但这两种方法都是
main 方法中主动将数据传入线程类的。这对于线程来说，是被动接收这些数据的。然而，在有些应用中需要在线程运行的过程中动态地获取数据，如在下面代码的 run 方法中产生了 3 个随机数，然后通过 Work 类的
process 方法求这三个随机数的和，并通过 Data 类的 value 将结果返回。从这个例子可以看出，在返回 value 之前，必须要得到三个随机数。也就是说，这个 value 是无法事先就传入线程类的。

/**
 * 回调实现多线程传递数据
 * Created by Sean on 2017/5/9.
 */
class Data {
    public int value = 0;
}

class Work {
    public void process(Data data, Integer[] numbers) {
        for (int n : numbers) {
            data.value += n;
        }
    }
}


class Thread10 extends Thread {
    private Work work;

    public Thread10(Work work) {
        this.work = work;
    }

    @Override
    public void run() {
        super.run();
        Integer[] numbers = new Integer[3];
        java.util.Random random = new java.util.Random();
        Data data = new Data();
        for (int i = 0; i < numbers.length; i++) {
            numbers[i] = random.nextInt(100);
        }
        work.process(data,numbers);
        System.out.println(String.valueOf(numbers[0]) + "+" + String.valueOf(numbers[1]) + "+"
                + String.valueOf(numbers[2]) + "=" + data.value);
    }

    public static void main(String[] args)
    {
        Thread thread = new Thread10(new Work());
        thread.start();
    }
}

多线程就写到这里了，基本都是按照这篇博客敲的，每个贴的代码都是亲自重写、验证，都是可执行的，虽然花了很多时间，但是自己对多线程有了更深层次的认识，希望这篇文章可以帮到大家。

林炳文Evankaka原创作品。出处http://blog.csdn.net/evankaka

Java多线程基础学习

写在前面的话：

一、扩展java.lang.Thread类

二、实现 java.lang.Runnable 接口

使用继承 Thread 实现共享的错误示范

三、Thread和Runnable的区别

使用继承 Thread 的方式共享的错误示例

使用实现 Runnable 实现共享票数

使用继承 Thread 的方式共享的正确示例

四、线程状态转换

五、线程调度

1. 调整线程优先级

2. 线程睡眠

3. 线程等待

4. 线程让步

5. 线程加入

6. 线程唤醒

六、常用函数说明

1. sleep(long millis): 在指定的毫秒数内让当前正在执行的线程休眠（暂停执行）

2. join() 指等待t线程终止。

使用方式

为什么要用join()方法

3. yield():暂停当前正在执行的线程对象，并执行其他线程。

sleep()和yield()的区别

4. setPriority(): 更改线程的优先级。

5. interrupt()

6. wait() 暂停线程，释放 cpu 控制权，同时释放对象锁的控制

wait() 和 sleep() 区别

sleep() 方法

wait() 方法

七、常见线程名词解释以及常用方法

1. 名词解释

2. 线程类的一些常用方法：

八、线程同步

1、synchronized关键字的作用域

2、synchronized关键字实现互斥访问

3. 不能继承

4. 用法

把synchronized当作函数修饰符时

2. 同步块

3. 将synchronized作用于static 函数

总结

九、线程数据传递

1. 通过构造方法传递数据

2. 通过变量和方法传递数据

3. 通过回调函数传递数据

相关文章

网友评论

延伸阅读

深度阅读

栏目导航

热点阅读

Android进阶之路

Android_Speak

Android知识

Java学习笔记

Android知识点和文章分享

技术干货

多线程与并发编程

1. `sleep(long millis)`: 在指定的毫秒数内让当前正在执行的线程休眠（暂停执行）

2. `join()` 指等待t线程终止。