（JAVA高并发程序设计）第二章、java并行程序基础

（JAVA高并发程序设计）第二章、java并行程序基础 一、线程的基本 *** 作

进行Java并发设计的第一步，就是必须要了解Java中为线程 *** 作所提供的一些API。比如，如何新建并且启动线程，如何终止线程、中断线程等。当然，因为并行 *** 作要比串行 *** 作复杂得多，于是，围绕着这些常用接口，可能有些比较隐晦的“坑”等着你去踩，而本节也会尽可能地将一些潜在问题描述清楚。
1.1、新建线程
新建线程很简单。只要使用new关键字创建一个线程对象，并且将它start()起来即可。

public class D1 {
    //新建线程
    public static void main(String[] args) {
        Thread a = new Thread();
        a.start();
    }
}

那么线程start()后，会干什么呢?这才是问题的关键。线程 Thread，有一个run()方法，start()方法就会新建一个线程并让这个线程执行run()方法。
这里要注意，下面的代码通过编译，也能正常执行。但是，却不能新建一个线程，而是在当前线程中调用run()方法，只是作为一个普通的方法调用。

public class D1 {
    //新建线程
    public static void main(String[] args) {
        Thread a = new Thread();
        a.run();
    }
}

因此，在这里希望大家特别注意，调用start()方法和直接调用run()方法的区别。
在默认情况下，线程Thread 的run()方法什么都没有做，因此，这个线程一启动就马上结束了。如果你想让线程做点什么，就必须重写run()方法，把你的“任务”填进去。

public class D1 {
    //新建线程
    public static void main(String[] args) {
        Thread a = new Thread() {
            public void run() {
                System.out.println("hello world");
            }
        };
        a.start();
    }
}

上述代码使用匿名内部类，重写了run()方法，并要求线程在执行时打印“Hello, I am t1”的字样。如果没有特别的需要，都可以通过继承线程Thread，重写run()方法来自定义线程。但考虑到Java是单继承的，也就是说继承本身也是一种很宝贵的资源，因此，我们也可以使用Runnable接口来实现同样的 *** 作。Runnable接口是一个单方法接口，它只有一个run()方法:

public interface Runnable {
    
    public abstract void run();
}

单纯的用接口来创建线程也是最常用的方法

public class Th1 implements Runnable {
    public void run() {
        System.out.println("Th1");
    }
}

1.2 终止线程
一般来说，线程执行完毕就会结束，无须手工关闭。但是，凡事都有例外。一些服务端的后台线程可能会常驻系统，它们通常不会正常终结。比如，它们的执行体本身就是一个大大的无穷循环，用于提供某些服务。
那么如何正常地关闭一个线程呢?查阅JDK,你不难发现线程Thread提供了一个stopO方法。如果你使用stop()方法,就可以立即将一个线程终止，非常方便。但如果你使用Eclipse之类的IDE 写代码，就会发现stop()方法是一个被标注为废弃的方法。也就是说，在将来，JDK可能就会移除该方法。
为什么stop)方法被废弃而不推荐使用呢?原因是 stop()方法过于暴力，强行把执行到一半的线程终止，可能会引起一些数据不一致的问题。
为了让大家更好地理解本节内容，我先简单介绍一些有关数据不一致的概念。假设我们在数据库里维护着一张用户表，里面记录了用户ID和用户名。假设这里有两条记录:

如果我们用一个User对象去保存这些记录，我们总是希望这个对象要么保存记录1，要么保存记录2。如果这个User对象一半存着记录1，另外一半存着记录2，我想大部分人都会抓狂吧!如果现在真的由于程序问题，出现了这么一个怪异的对象u，u的ID是1，但是u的NAME是小王。那么，在这种情况下，数据就已经不一致了，说白了就是系统有错误了。这种情况是相当危险的，如果我们把一个不一致的数据直接写入了数据库，那么就会造成数据永久地被破坏和丢失，后果不堪设想。
也许有人会问，怎么可能呢?跑得好好的系统，怎么会出现这种问题呢?在单线程环境中，确实不会，但在并行程序中，如果考虑不周，就有可能出现类似的情况。不经思考地使用stop)方法就有可能导致这种问题。
Thread.stop()方法在结束线程时，会直接终止线程，并立即释放这个线程所持有的锁，而这些锁恰恰是用来维持对象一致性的。如果此时，写线程写入数据正写到一半，并强行终止，那么对象就会被写坏，同时，由于锁已经被释放，另外一个等待该锁的读线程就顺理成章地读到了这个不一致的对象，悲剧也就此发生。
如果需要停止一个线程，那么应该怎么做呢?其实方法很简单，只需要由我们自行决定线程何时退出就可以了。仍然用本例说明，只需要将ChangeObjectThread 线程增加一个stopMe()方法即可。
1.3 线程中断
在Java 中，线程中断是一种重要的线程协作机制。从表面上理解，中断就是让目标线程停止执行的意思，实际上并非完全如此。在上一节中，我们已经详细讨论了stop()方法停止线程的坏处，并且使用了一套自有的机制完善线程退出的功能。在 JDK中是否有提供更强大的支持呢?答案是肯定的，那就是线程中断。
严格地讲，线程中断并不会使线程立即退出，而是给线程发送一个通知，告知目标线程，有人希望你退出啦!至于目标线程接到通知后如何处理，则完全由目标线程自行决定。这点很重要，如果中断后，线程立即无条件退出，我们就又会遇到 stop()方法的老问题。
有三个方法与线程中断有关，这三个方法看起来很像，可能会引起混淆和误用，希望大家注意。

Thread.interrupt)方法是一个实例方法。它通知目标线程中断，也就是设置中断标志位。中断标志位表示当前线程已经被中断了。Thread.isInterrupted()方法也是实例方法，它判断当前线程是否被中断（通过检查中断标志位）。最后的静态方法Thread.interrupted()也可用来判断当前线程的中断状态，但同时会清除当前线程的中断标志位状态。
1.4 等待和通知
为了支持多线程之间的协作，JDK提供了两个非常重要的接口线程:等待wait()方法和通知notify)方法。这两个方法并不是在Thread类中的，而是输出 Object类。这也意味着任何对象都可以调用这两个方法。
这两个方法的签名如下:

当在一个对象实例上调用wait)方法后，当前线程就会在这个对象上等待。这是什么意思呢?比如，在线程A中，调用了obj.wait()方法，那么线程A就会停止继续执行，转为等待状态。等待到何时结束呢?线程A会一直等到其他线程调用了obj.notify()方法为止。这时，object对象俨然成了多个线程之间的有效通信手段。
那么wait()方法和 notify()方法究竟是如何工作的呢?图2.5展示了两者的工作过程。如果一个线程调用了object.wait()方法，那么它就会进入 object对象的等待队列。这个等待队列中，可能会有多个线程，因为系统运行多个线程同时等待某一个对象。当 object.notify()方法被调用时，它就会从这个等待队列中随机选择一个线程，并将其唤醒。这里希望大家注意的是，这个选择是不公平的，并不是先等待的线程就会优先被选择，这个选择完全是随机的。

除notify()方法外，Object对象还有一个类似的notifyAll()方法，它和 notify()方法的功能基本一致，不同的是，它会唤醒在这个等待队列中所有等待的线程，而不是随机选择一个。
这里还需要强调一点，Object.wait()方法并不能随便调用。它必须包含在对应的synchronzied语句中，无论是wait()方法或者notify()方法都需要首先获得目标对象的一个监视器。图2.6显示了wait()方法和notify()方法的工作流程细节。其中T1和T2表示两个线程。T1在正确执行wait()方法前，必须获得object对象的监视器。而 wait()方法在执行后，会释放这个监视器。这样做的目的是使其他等待在object对象上的线程不至于因为T1的休眠而全部无法正常执行。
线程T2在notify)方法调用前，也必须获得object对象的监视器。所幸，此时T1已经释放了这个监视器。因此，T2可以顺利获得object对象的监视器。接着，T2执行了notifyO方法尝试唤醒一个等待线程，这里假设唤醒了T1。T1在被唤醒后，要做的第一件事并不是执行后续的代码，而是要尝试重新获得 object对象的监视器，而这个监视器也正是T1在wait()方法执行前所持有的那个。如果暂时无法获得，则T1还必须等待这个监视器。当监视器顺利获得后，T1才可以在真正意义上继续执行。

1.5 挂起和继续执行
如果你阅读JDK有关Thread类的API文档,可能还会发现两个看起来非常有用的接口，即线程挂起( suspend）和继续执行（resume)。这两个 *** 作是一对相反的 *** 作，被挂起的线程,必须要等到resume()方法 *** 作后,才能继续指定。乍看之下,这对 *** 作就像Thread.stop(方法一样好用。但如果你仔细阅读文档说明，会发现它们也早已被标注为废弃方法，并不推荐使用。
不推荐使用suspend)方法去挂起线程是因为suspend()方法在导致线程暂停的同时，并不会释放任何锁资源。此时，其他任何线程想要访问被它占用的锁时，都会被牵连，导致无法正常继续运行（如图2.7所示)。直到对应的线程上进行了resume()方法 *** 作，被挂起的线程才能继续,从而其他所有阻塞在相关锁上的线程也可以继续执行。但是,如果resume()方法 *** 作意外地在 suspend()方法前就执行了，那么被挂起的线程可能很难有机会被继续执行。并且，更严重的是:它所占用的锁不会被释放，因此可能会导致整个系统工作不正常。而且，对于被挂起的线程，从它的线程状态上看，居然还是 Runnable，这也会严重影响我们对系统当前状态的判断。

未完待续。。。。