20-多线程

20.1线程简介
世间有很多工作都是可以同时完成的。例如，人体可以同时进行呼吸、血液循环、思考问题等活用户既可以使用计算机听歌，也可以使用它打印文件。同样，计算机完全可以将多种活动同时进这种思想放在 Java 中被称为并发，而将并发完成的每一件事情称为线程。在Java 中，并发机制非常重要。在以往的程序设计中，我们都是一个任务完成后再进行下一个任，这样下一个任务的开始必须等待前一个任务的结束。Java 语言提供了并发机制，程序员可以在程r中执行多个线程，每一个线程完成一个功能，并与其他线程并发执行，这种机制被称为多线程

20.2创建线程
在Java中主要提供两种方式实现线程，分别继承java.lang.Thread类与实现java.lang.Runnable接口

20.2.1继承Thread类
Thread 类是java.lang 包中的一个类，从这个类中实例化的对象代表线程，程序员启动一个新线需要建立Thread实例。Thread 类中常用的两个构造方法如下:口 public Thread0:创建一个新的线程对象。
口 public Thread(String threadName): 创建一个名称为 threadName 的线程对象继承Thread类创建一个新的线程的语法如下:
public class ThreadTest extends Thread!
完成线程真正功能的代码放在类的run（）方法中，当一个类继承 Thread类后，就可以在该类中影run（）方法，将实现该线程功能的代码写入run（）方法中，然后调用 Thread类中的start（）方法执行线
也就是调用run（）方法。

Thread 对象需要一个任务来执行，任务是指线程在启动时执行的工作，该工作的功能代码被写#run0方法中。run0方法必须使用以下语法格式:
public void run()

注意
如果 start0)方法调用一个已经启动的线程，系统将抛出 IllegalThreadStateException 异常
例题1

20.2.2实现Runnable接口
说明

? ? ? ? 可以查询API，从中可以发现，实质上Thread类实现了Runnable接口，其中的run（）方法正是对Runnable接口中的run（）方法的具体实现。

实现Runnable接口的程序会创建一个Thread对象，并将Runnable对象与Thraed对象相关联，Thread类中有以下两个构造方法：

public Thread(Runnable target).

public Thread(Runnable target,Strug name)

这两个构造方法的参数中都存在Runnable实例，使用以上构造方法就可以江Runnable实例与T和Thread实例相关联。

20.3线程的生命周期

例题2

20.4操作线程的方法
20.4.1线程的休眠
一种能控制线程行为的方法是调用 sleep方法,seep0方法需要一个参数用于指定该线程休眠的时间，该时间以毫秒为单位。在前面的实例中，已经演示过 sleep0方法，它通常是在 run0方法内的循环中被使用。sleep0方法的语法如下:

try{
Thread.sleep(2000);
}catch(InterruptedException e){
e.printStackTrace();
}
上述代码会使线程在 2 秒之内不会进入就绪状态。由于 sleep0方法的执行有可能抛出terruptedException 异常，所以将 sleep0方法的调用放在 try-catch 块中。虽然使用了 sleep0方法的线程一段时间内会醒来，但是并不能保证它醒来后进入运行状态，只能保证它进入就绪状态。?

例题3
package ershi;
?
import java.awt.*;
import java.awt.Graphics;
import java.util.Random;
import javax.swing.*;
?
public class SleepMethodTest extends JFrame{
? ? private static Color[] color= {Color.BLACK,Color.BLUE,Color.CYAN,Color.GREEN,Color.ORANGE,Color.YELLOW,Color.RED,Color.PINK,Color.LIGHT_GRAY};
? ? private static final Random rand=new Random();
? ??
? ? private static Color getC() {
? ? ? ? return color[rand.nextInt(color.length)];
? ? }
? ? public SleepMethodTest() {
? ? ? ? Thread t=new Thread(new Runnable() {
? ? ? ? ? ? int x=30;
? ? ? ? ? ? int y=50;
? ? ? ? ? ??
? ? ? ? ? ? public void run() {
? ? ? ? ? ? ? ? while(true) {
? ? ? ? ? ? ? ? ? ? try {
? ? ? ? ? ? ? ? ? ? ? ? Thread.sleep(100);
? ? ? ? ? ? ? ? ? ? }catch(InterruptedException e){
? ? ? ? ? ? ? ? ? ? ? ? e.printStackTrace();
? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? Graphics graphics =getGraphics();
? ? ? ? ? ? ? ? ? ? graphics.setColor(getC());
? ? ? ? ? ? ? ? ? ? graphics.drawLine(x, y, 100, y++);
? ? ? ? ? ? ? ? ? ? if(y>=80) {
? ? ? ? ? ? ? ? ? ? ? ? y=50;
? ? ? ? ? ? ? ? ? ? } ? ?} ? ?} ? ?});
? ? ? ? t.start();
? ? }
? ? public static void main(String[] args) {
? ? ? ? init(new SleepMethodTest(),100,100);
? ? }
? ? public static void init(JFrame frame,int width, int height) {
? ? ? ? frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
? ? ? ? frame.setSize(width, height);
? ? ? ? frame.setVisible(true);
? ? }
}

20.4.2线程的加入
如果当前某程序为多线程程序，假如存在一个线程 A，现在需要插入线程 B，并要求线程B免行完毕，然后再继续执行线程 A，此时可以使用 Thread 类中的join0方法来完成。这就好比此时读者在看电视，突然有人上门收水费，读者必须付完水费后才能继续看电视。当某个线程使用 join(方法加入另外一个线程时，另一个线程会等待该线程执行完毕后再缘续行。下面来看一个使用join0方法的实例。

例题4

package ershi;
?
import java.awt.BorderLayout;
?
import javax.swing.JFrame;
import javax.swing.JProgressBar;
?
public class JoinTest extends JFrame{
? ? private Thread threadA;
? ? private Thread threadB;
? ? private JProgressBar progressBar=new JProgressBar();
? ? private JProgressBar progressBar2=new JProgressBar();
? ??
? ? public static void main(String[] args) {
? ? ? ? JoinTest test = new JoinTest();
? ? ? ? test.setVisible(true);
? ? }
? ? public JoinTest() {
? ? ? ? setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
? ? ? ? setBounds(200,200,200,100);
? ? ? ? getContentPane().add(progressBar,BorderLayout.NORTH);
? ? ? ? getContentPane().add(progressBar2,BorderLayout.SOUTH);
? ? ? ? progressBar.setStringPainted(true);
? ? ? ? progressBar2.setStringPainted(true);
? ? ? ? threadA=new Thread(new Runnable() {
? ? ? ? ? ? int count =0;
? ? ? ? ? ? public void run() {
? ? ? ? ? ? ? ? while(true) {
? ? ? ? ? ? ? ? ? ? progressBar.setValue(++count);
? ? ? ? ? ? ? ? ? ? try {
? ? ? ? ? ? ? ? ? ? ? ? Thread.sleep(100);
? ? ? ? ? ? ? ? ? ? ? ? threadB.join();
? ? ? ? ? ? ? ? ? ? }catch(InterruptedException e) {
? ? ? ? ? ? ? ? ? ? ? ? e.printStackTrace();
? ? ? ? ? ? ? ? ? ? }}} ? ?});
? ? ? ? threadA.start();
? ? ? ??
? ? ? ? threadB=new Thread(new Runnable() {
? ? ? ? ? ? int count =0;
? ? ? ? ? ? public void run() {
? ? ? ? ? ? ? ? while(true) {
? ? ? ? ? ? ? ? ? ? progressBar2.setValue(++count);
? ? ? ? ? ? ? ? ? ? try {
? ? ? ? ? ? ? ? ? ? ? ? Thread.sleep(100);
? ? ? ? ? ? ? ? ? ? }catch(InterruptedException e) {
? ? ? ? ? ? ? ? ? ? ? ? e.printStackTrace();
? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? if(count==100)
? ? ? ? ? ? ? ? ? ? break;
? ? ? ? ? ? ? ? ? ? }}});
? ? ? ? threadB.start();
? ? }

20.4.3线程的中断
以往有的时候会使用 stop0方法停止线程，但当前版本的JDK 早已废除了 stop0方法，不建议愤stop0方法来停止一个线程的运行。现在提倡在 run0方法中使用无限循环的形式，然后使用一个布尔
标记控制循环的停止。如果线程是因为使用了 sleep0或 wait0方法进入了就绪状态，可以使用 Thread类中intemupt0方注使线程离开 run0方法，同时结束线程，但程序会抛出InterruptedException 异常，用户可以在处理滨常时完成线程的中断业务处理，如终止 while 循环。
下面的实例演示了某个线程使用 interrupted0方法，同时程序抛出了 InterruptedException异常，在异常处理时结束了 while 循环。在项目中，经常在这里执行关闭数据库连接和关闭 Socket 连接等作

例题5
package ershi;
?
import java.awt.BorderLayout;
import java.awt.Component;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
?
import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JProgressBar;
?
public class InterruptedSwing extends JFrame{
? ??
? ? public InterruptedSwing(){
? ? ? ? JProgressBar progressBar=new JProgressBar();
? ? ? ? getContentPane().add(progressBar,BorderLayout.NORTH);
? ? ? ? JButton button =new JButton("停止");
? ? ? ? Component progressBar2;
? ? ? ? getContentPane().add(button,BorderLayout.SOUTH);
? ? ? ? progressBar.setStringPainted(true);
? ? ? ? Thread t=new Thread(new Runnable() {
? ? ? ? ? ? int count =0;
? ? ? ? ? ? public void run() {
? ? ? ? ? ? ? ? while(true) {
? ? ? ? ? ? ? ? ? ? progressBar.setValue(++count);
? ? ? ? ? ? ? ? ? ? try {
? ? ? ? ? ? ? ? ? ? ? ? Thread.sleep(100);
? ? ? ? ? ? ? ? ? ? }catch(InterruptedException e) {
? ? ? ? ? ? ? ? ? ? ? ? System.out.println("当前线程被中断");
? ? ? ? ? ? ? ? ? ? ? ? break;
? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? }
? ? ? ? ? ? }
? ? ? ? });
? ? ? ? ? ? ? ? ? ? button.addActionListener((ActionListener) new ActionListener() {
? ? ? ? ? ? ? ? ? ? ? ? @Override
? ? ? ? ? ? ? ? ? ? ? ? public void actionPerformed(ActionEvent e) {
? ? ? ? ? ? ? ? ? ? ? ? ? ? t.interrupt();
? ? ? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? });
? ? ? ? ? ? ? ? ? ? t.start();
? ? ? ? }
? ? public static void init(JFrame frame,int width, int height) {
? ? ? ? frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
? ? ? ? frame.setSize(width,height);
? ? ? ? frame.setVisible(true);
? ? }
? ? public static void main(String[] args) {
? ? ? ? init(new InterruptedSwing(),100,100);
? ? }
}

20.4.4线程的礼让
Thread类中提供了一种礼让方法使用——yiled（）方法表示

它只是给当前正处于运行状态的线程一个提醒，告知它可以将资源礼让给其他线程

但这仅是一个暗示，没有任何以一种机制保证当前线程会将资源礼让

20.5线程的优先级
每个线程都具有各自的优先级，线程的优先级可以表明在程序中该线程的重要性，如果有很多线程处于就绪状态，系统会根据优先级来决定首先使哪个线程进入运行状态。但这并不意味着低优先级的线程得不到运行，而只是它运行的概率比较小，如垃圾回收线程的优先级就较低

Thread 类中包含的成员变量代表了线程的某些优先级，如 ThreadMIN PRIORITY(常数 1)ThreadMAX PRIORITY(常数 10)ThreadNORM PRIORITY(常数 5)。其中，每个线程的优先级都在ThreadMIN PRIORITY~ThreadMAX PRIORITY，在默认情况下其优先级都是 ThreadNORMPRIORITY。每个新产生的线程都继承了父线程的优先级。
在多任务操作系统中，每个线程都会得到一小段 CPU 时间片运行，在时间结束时，将轮换另一个线程进入运行状态，这时系统会选择与当前线程优先级相同的线程予以运行。系统始终选择就绪状态下优线程B线程A先级较高的线程进入运行状态。

例题6
package ershi;
?
public class PriorityTest implements Runnable {
? ? String name;
? ??
? ? public PriorityTest(String name) {
? ? ? ? this.name=name;
? ? }
? ? @Override
? ? public void run() {
? ? ? ? String tmp="";
? ? ? ? for(int i= 0;i<50000;i++) {
? ? ? ? ? ? tmp +=i;
? ? ? ? }
? ? ? ? System.out.println(name+"线程完成任务");
? ? }
? ? public static void main(String[] args) {
? ? ? ? Thread a=new Thread(new PriorityTest("A"));
? ? ? ? a.setPriority(1);
? ? ? ? Thread b=new Thread(new PriorityTest("B"));
? ? ? ? a.setPriority(3);
? ? ? ? Thread c=new Thread(new PriorityTest("C"));
? ? ? ? a.setPriority(7);
? ? ? ? Thread d=new Thread(new PriorityTest("D"));
? ? ? ? a.setPriority(10);
? ? ? ? a.start();
? ? ? ? b.start();
? ? ? ? c.start();
? ? ? ? d.start();
? ? }
}

结果

20.6线程同步
单线程只能做一件事，后面的事情需要前面的事情完成后才可以进行，但如果使用多线程，就会发生两个线程抢占资源的问题，

防止这些资源访问的冲突、Java提供了线程同步的机制来防止访问的冲突

20.6.1线程安全
实际开发中、使用多线程程序的情况很多，如银行排号系统、火车站售票系统等。这种多线程的程李通常会爱生问题，以大车站售票系统为例，在代码中判断当前票数是否大于 0，如果大于0则执行蕊该票出售绘乘客的功能，但当两个线程同时访问这段代码时(假如这时只剩下一张票)，第一个线稳蒋票售出，与此同时第二个线程也已经执行完成判断是否有票的操作，并得出票数大于0的结论，是它也获行售出操作，这样就会产生负数。所以，在编写多线程程序时，应该考虑到线程安全问题实质上线程安全问题来源于两个线程同时存取单一对象的数据。
锅如，在项目中创建 ThreadSafeTest 类，该类实现了 Runnable 接口，在未考虑到线程安全问题的基础上，模拟火车站售票系统的功能的代码如下:

示例

package ershi;
?
public class ThreadSafeTest implements Runnable{
? ? int num=10;
? ? ??
? ? public void run() {
? ? ? ? ? ? while(true) {
? ? ? ? ? ? ? ??
? ? ? ? ? ? ? ? if(num>0) {
? ? ? ? ? ? ? ? try {
? ? ? ? ? ? ? ? ? ? Thread.sleep(500);
? ? ? ? ? ? ? ? }catch(InterruptedException e) {
? ? ? ? ? ? ? ? ? ? e.printStackTrace();
? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? System.out.println(Thread.currentThread().getName()+"————票数"+num--);
? ? ? ? ? ? ? ? }
? ? ? ? ? ? }
? ? ? ? }
? ? public static void main(String[] args) {
? ? ? ? ThreadSafeTest t =new ThreadSafeTest();
? ? ? ? Thread tA = new Thread(t,"线程一");
? ? ? ? Thread tB = new Thread(t,"线程二");
? ? ? ? Thread tC = new Thread(t,"线程三");
? ? ? ? Thread tD = new Thread(t,"线程四");
? ? ? ? tA.start();
? ? ? ? tB.start();
? ? ? ? tC.start();
? ? ? ? tD.start();
? ? }
}

结果

20.6.2线程同步机制
1.同步块
Java中提供了同步机制，可以有效的防止资源冲突，同步机制使用synchronized关键字，使用该关键字包含的代码块称为同步块，也称临界区语法如下：

synchronized(Object){
?
}
通常将共享资源 synchronized定义的区域内，这样当其他线程获取这个锁时，就必须等待被释放后才可以进入该区域

2同步方法
同步方法就是在方法面前使用synchronized关键字修饰的方法，语法如下:

synchronized void f（）{}

当某个对象调用同步方法时该对象的其他方法必须等待该同步方法执行完毕后才能被执行

例题7
package ershi;
?
public class ThreadSafeTest implements Runnable{
? ? int num=10;
? ? ??
? ? public void run() {
? ? ? ? ? ? while(true) {
? ? ? ? ? ? ? ? synchronized(this) {
? ? ? ? ? ? ? ? if(num>0) {
? ? ? ? ? ? ? ? try {
? ? ? ? ? ? ? ? ? ? Thread.sleep(500);
? ? ? ? ? ? ? ? }catch(InterruptedException e) {
? ? ? ? ? ? ? ? ? ? e.printStackTrace();
? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? System.out.println(Thread.currentThread().getName()+"————票数"+num--);
? ? ? ? ? ? ? ? }
? ? ? ? ? ? }
? ? ? ? }
? ? }
? ? public static void main(String[] args) {
? ? ? ? ThreadSafeTest t =new ThreadSafeTest();
? ? ? ? Thread tA = new Thread(t,"线程一");
? ? ? ? Thread tB = new Thread(t,"线程二");
? ? ? ? Thread tC = new Thread(t,"线程三");
? ? ? ? Thread tD = new Thread(t,"线程四");
? ? ? ? tA.start();
? ? ? ? tB.start();
? ? ? ? tC.start();
? ? ? ? tD.start();
? ? }
}

结果