Java多线程3

• 了解进程与线程的区别。
• 掌握Java多线程的两种实现方式及区别。
• 了解线程的状态变化。
• 了解多线程的主要操作方法 。
• 了解同步及死锁的概念。

进程与线程

进程是程序的一次动态执行过程，它需要经历从代码加载，代码执行到执行完毕的一个完整的过程，这个过程也是进程本身从产生，发展到最终消亡的过程。多进程操作系统能同时达运行多个进程（程序），由于CPU具备分时机制，所以每个进程都能循环获得自己的CPU时间片。由于CPU执行速度非常快，使得所有程序好像是在同时运行一样。

多线程是实现并发机制的一种有效手段。进程和线程一样，都是实现并发的一个基本单位。线程是比进程更小的执行单位，线程是进程的基础之上进行进一步的划分。所谓多线程是指一个进程在执行过程中可以产生多个更小的程序单元，这些更小的单元称为线程，这些线程可以同时存在，同时运行，一个进程可能包含多个同时执行的线程。进程与线程的区别如图所示： 

Java中线程的实现

在Java中实现多线程有两种手段，一种是继承Thread类，另一种就是实现Runnable接口。下面我们就分别来介绍这两种方式的使用。

(一)实现Runnable接口

package ljz;
class MyThread implements Runnable{ // 实现Runnable接口，作为线程的实现类private String name ;       // 表示线程的名称public MyThread(String name){this.name = name ;      // 通过构造方法配置name属性}public void run(){  // 覆写run()方法，作为线程 的操作主体for(int i=0;i<10;i++){System.out.println(name + "运行，i = " + i) ;}}
};
public class RunnableDemo01{public static void main(String args[]){MyThread mt1 = new MyThread("线程A ") ;    // 实例化对象MyThread mt2 = new MyThread("线程B ") ;    // 实例化对象Thread t1 = new Thread(mt1) ;       // 实例化Thread类对象Thread t2 = new Thread(mt2) ;       // 实例化Thread类对象t1.start() ;    // 启动多线程t2.start() ;    // 启动多线程}
};

程序运行结果： 

(二)继承Thread类

class MyThread extends Thread{  // 继承Thread类，作为线程的实现类private String name ;       // 表示线程的名称public MyThread(String name){this.name = name ;      // 通过构造方法配置name属性}public void run(){  // 覆写run()方法，作为线程 的操作主体for(int i=0;i<10;i++){System.out.println(name + "运行，i = " + i) ;}}
};
public class ThreadDemo02{public static void main(String args[]){MyThread mt1 = new MyThread("线程A ") ;    // 实例化对象MyThread mt2 = new MyThread("线程B ") ;    // 实例化对象mt1.start() ;   // 调用线程主体mt2.start() ;   // 调用线程主体}
};

程序运行结果： 

从程序可以看出，现在的两个线程对象是交错运行的，哪个线程对象抢到了CPU资源，哪个线程就可以运行，所以程序每次的运行结果肯定是不一样的，在线程启动虽然调用的是start()方法，但实际上调用的却是run()方法定义的主体。

Thread类与Runnable接口

通过Thread类和Runable接口都可以实现多线程，那么两者有哪些联系和区别呢？下面我们观察Thread类的定义。

public class Thread extends Object implements Runnable

从Thread类的定义可以清楚的发现，Thread类也是Runnable接口的子类，但在Thread类中并没有完全实现Runnable接口中的run()方法，下面是Thread类的部分定义。

Private Runnable target；
public Thread(Runnable target,String name){
init(null,target,name,0);
}
private void init(ThreadGroup g,Runnable target,String name,long stackSize){
...
this.target=target;}
public void run(){
if(target!=null){
target.run();}
}

从定义中可以发现，在Thread类中的run（）方法调用的是Runnable接口中的run()方法，也就是说此方法是由Runnable子类完成的，所以如果要通过继承Thread类实现多线程，则必须覆写run()。

实际上Thread类和Runnable接口之间在使用上也是有区别的，如果一个类继承Thread类，则不适合于多个线程共享资源，而实现了Runnable接口，就可以方便的实现资源的共享。

线程的状态

要想实现多线程，必须在主线程中创建新的线程对象。任何线程一般具有5种状态，即创建，就绪，运行，阻塞，终止。下面分别介绍一下这几种状态：

• 创建状态 
  在程序中用构造方法创建了一个线程对象后，新的线程对象便处于新建状态，此时它已经有了相应的内存空间和其他资源，但还处于不可运行状态。新建一个线程对象可采用Thread类的构造方法来实现，例如“Thread thread=new Thread()”。

• 就绪状态 
  新建线程对象后，调用该线程的start()方法就可以启动线程。当线程启动时，线程进入就绪状态。此时，线程将进入线程队列排队，等待CPU服务，这表明它已经具备了运行条件。

• 运行状态 
  当就绪状态被调用并获得处理器资源时，线程就进入了运行状态。此时，自动调用该线程对象的run()方法。run()方法定义该线程的操作和功能。

• 阻塞状态 
  一个正在执行的线程在某些特殊情况下，如被人为挂起或需要执行耗时的输入/输出操作，会让CPU暂时中止自己的执行，进入阻塞状态。在可执行状态下，如果调用sleep(),suspend(),wait()等方法，线程都将进入阻塞状态，发生阻塞时线程不能进入排队队列，只有当引起阻塞的原因被消除后，线程才可以转入就绪状态。

• 死亡状态 
  线程调用stop()方法时或run()方法执行结束后，即处于死亡状态。处于死亡状态的线程不具有继续运行的能力。

在此提出一个问题

Java程序每次运行至少启动几个线程？

回答：至少启动两个线程，每当使用Java命令执行一个类时，实际上都会启动一个JVM，每一个JVM实际上就是在操作系统中启动一个线程，Java本身具备了垃圾的收集机制。所以在Java运行时至少会启动两个线程，一个是main线程，另外一个是垃圾收集线程。

取得和设置线程的名称

class MyThread implements Runnable{ //实现Runnable接口public void run(){for(int i=0;i<3;i++){System.Out.Println(Thread.currentThread().getName()+"运行, i="+i);  //取得当前线程的名称}}
};public class ThreadDemo{
public static void main(String args[]){
MyThread my=new MyThread();  //定义Runnable子类对象
new Thread(my).start;    //系统自动设置线程名称
new Thread(my,"线程A").start();  //手工设置线程名称}
};  

程序运行结果： 

线程的强制运行

在线程操作中，可以使用join()方法让一个线程强制运行，线程强制运行期间，其他线程无法运行，必须等待此线程完成之后才可以继续执行。

class MyThread implements Runnable{ // 实现Runnable接口public void run(){  // 覆写run()方法for(int i=0;i<50;i++){System.out.println(Thread.currentThread().getName()+ "运行，i = " + i) ;  // 取得当前线程的名字}}
};
public class ThreadJoinDemo{public static void main(String args[]){MyThread mt = new MyThread() ;  // 实例化Runnable子类对象Thread t = new Thread(mt,"线程");     // 实例化Thread对象t.start() ; // 启动线程for(int i=0;i<50;i++){if(i>10){try{t.join() ;  // 线程强制运行}catch(InterruptedException e){}}System.out.println("Main线程运行 --> " + i) ;}}
};

程序运行结果： 

线程的休眠

class MyThread implements Runnable{ // 实现Runnable接口public void run(){  // 覆写run()方法for(int i=0;i<50;i++){try{Thread.sleep(500) ; // 线程休眠}catch(InterruptedException e){}System.out.println(Thread.currentThread().getName()+ "运行，i = " + i) ;  // 取得当前线程的名字}}
};
public class ThreadSleepDemo{public static void main(String args[]){MyThread mt = new MyThread() ;  // 实例化Runnable子类对象Thread t = new Thread(mt,"线程");     // 实例化Thread对象t.start() ; // 启动线程}
};

中断线程

当一个线程运行时，另外一个线程可以直接通过interrupt()方法中断其运行状态。

class MyThread implements Runnable{ // 实现Runnable接口public void run(){  // 覆写run()方法System.out.println("1、进入run()方法") ;try{Thread.sleep(10000) ;   // 线程休眠10秒System.out.println("2、已经完成了休眠") ;}catch(InterruptedException e){System.out.println("3、休眠被终止") ;return ; // 返回调用处}System.out.println("4、run()方法正常结束") ;}
};
public class ThreadInterruptDemo{public static void main(String args[]){MyThread mt = new MyThread() ;  // 实例化Runnable子类对象Thread t = new Thread(mt,"线程");     // 实例化Thread对象t.start() ; // 启动线程try{Thread.sleep(2000) ;    // 线程休眠2秒}catch(InterruptedException e){System.out.println("3、休眠被终止") ;}t.interrupt() ; // 中断线程执行}
};

程序运行结果： 

后台线程

在Java程序中，只要前台有一个线程在运行，则整个Java进程都不会消失，所以此时可以设置一个后台线程，这样即使Java线程结束了，此后台线程依然会继续执行，要想实现这样的操作，直接使用setDaemon()方法即可。

class MyThread implements Runnable{ // 实现Runnable接口public void run(){  // 覆写run()方法while(true){System.out.println(Thread.currentThread().getName() + "在运行。") ;}}
};
public class ThreadDaemonDemo{public static void main(String args[]){MyThread mt = new MyThread() ;  // 实例化Runnable子类对象Thread t = new Thread(mt,"线程");     // 实例化Thread对象t.setDaemon(true) ; // 此线程在后台运行t.start() ; // 启动线程}
};

在线程类MyThread中，尽管run()方法中是死循环的方式，但是程序依然可以执行完，因为方法中死循环的线程操作已经设置成后台运行。

线程的优先级

在Java的线程操作中，所有的线程在运行前都会保持在就绪状态，那么此时，哪个线程的优先级高，哪个线程就有可能会先被执行。

class MyThread implements Runnable{ // 实现Runnable接口public void run(){  // 覆写run()方法for(int i=0;i<5;i++){try{Thread.sleep(500) ; // 线程休眠}catch(InterruptedException e){}System.out.println(Thread.currentThread().getName()+ "运行，i = " + i) ;  // 取得当前线程的名字}}
};
public class ThreadPriorityDemo{public static void main(String args[]){Thread t1 = new Thread(new MyThread(),"线程A") ;  // 实例化线程对象Thread t2 = new Thread(new MyThread(),"线程B") ;  // 实例化线程对象Thread t3 = new Thread(new MyThread(),"线程C") ;  // 实例化线程对象t1.setPriority(Thread.MIN_PRIORITY) ;   // 优先级最低t2.setPriority(Thread.MAX_PRIORITY) ;   // 优先级最高t3.setPriority(Thread.NORM_PRIORITY) ;  // 优先级最中等t1.start() ;    // 启动线程t2.start() ;    // 启动线程t3.start() ;    // 启动线程}
};

程序运行结果： 

从程序的运行结果中可以观察到，线程将根据其优先级的大小来决定哪个线程会先运行，但是需要注意并非优先级越高就一定会先执行，哪个线程先执行将由CPU的调度决定。

线程的礼让

在线程操作中，也可以使用yield()方法将一个线程的操作暂时让给其他线程执行

class MyThread implements Runnable{ // 实现Runnable接口public void run(){  // 覆写run()方法for(int i=0;i<5;i++){try{Thread.sleep(500) ;}catch(Exception e){}System.out.println(Thread.currentThread().getName()+ "运行，i = " + i) ;  // 取得当前线程的名字if(i==2){System.out.print("线程礼让：") ;Thread.currentThread().yield() ;    // 线程礼让}}}
};
public class ThreadYieldDemo{public static void main(String args[]){MyThread my = new MyThread() ;  // 实例化MyThread对象Thread t1 = new Thread(my,"线程A") ;Thread t2 = new Thread(my,"线程B") ;t1.start() ;t2.start() ;}
};

程序执行结果： 

同步与死锁

一个多线程的程序如果是通过Runnable接口实现的，则意味着类中的属性被多个线程共享，那么这样就会造成一种问题，如果这多个线程要操作同一个资源时就有可能出现资源同步问题。

解决方法：

• 同步代码块

syncchronized(同步对象)｛需要同步的代码
｝

class MyThread implements Runnable{private int ticket = 5 ;    // 假设一共有5张票public void run(){for(int i=0;i<100;i++){synchronized(this){ // 要对当前对象进行同步if(ticket>0){   // 还有票try{Thread.sleep(300) ; // 加入延迟}catch(InterruptedException e){e.printStackTrace() ;}System.out.println("卖票：ticket = " + ticket-- );}}}}
};
public class SyncDemo02{public static void main(String args[]){MyThread mt = new MyThread() ;  // 定义线程对象Thread t1 = new Thread(mt) ;    // 定义Thread对象Thread t2 = new Thread(mt) ;    // 定义Thread对象Thread t3 = new Thread(mt) ;    // 定义Thread对象t1.start() ;t2.start() ;t3.start() ;}
};

程序执行结果： 

• 
  
• 同步方法 

除了可以将需要的代码设置成同步代码块外，也可以使用synchronized 关键字将一个方法声明为同步方法。

synchronized 方法返回值 方法名称（参数列表）｛｝

class MyThread implements Runnable{private int ticket = 5 ;    // 假设一共有5张票public void run(){for(int i=0;i<100;i++){this.sale() ;   // 调用同步方法}}public synchronized void sale(){    // 声明同步方法if(ticket>0){   // 还有票try{Thread.sleep(300) ; // 加入延迟}catch(InterruptedException e){e.printStackTrace() ;}System.out.println("卖票：ticket = " + ticket-- );}}
};
public class SyncDemo03{public static void main(String args[]){MyThread mt = new MyThread() ;  // 定义线程对象Thread t1 = new Thread(mt) ;    // 定义Thread对象Thread t2 = new Thread(mt) ;    // 定义Thread对象Thread t3 = new Thread(mt) ;    // 定义Thread对象t1.start() ;t2.start() ;t3.start() ;}
};

程序运行结果： 

从程序运行的结果可以发现，此代码完成了与之前同步代码同样的功能。

死锁

同步可以保证资源共享操作的正确性，但是过多同步也会产生问题。例如，现在张三想要李四的画，李四想要张三的书，张三对李四说“把你的画给我，我就给你书”，李四也对张三说“把你的书给我，我就给你画”两个人互相等对方先行动，就这么干等没有结果，这实际上就是死锁的概念。

所谓死锁，就是两个线程都在等待对方先完成，造成程序的停滞，一般程序的死锁都是在程序运行时出现的。

下面以一个简单范例说明这个概念

class Zhangsan{ // 定义张三类public void say(){System.out.println("张三对李四说：“你给我画，我就把书给你。”") ;}public void get(){System.out.println("张三得到画了。") ;}
};
class Lisi{ // 定义李四类public void say(){System.out.println("李四对张三说：“你给我书，我就把画给你”") ;}public void get(){System.out.println("李四得到书了。") ;}
};
public class ThreadDeadLock implements Runnable{private static Zhangsan zs = new Zhangsan() ;       // 实例化static型对象private static Lisi ls = new Lisi() ;       // 实例化static型对象private boolean flag = false ;  // 声明标志位，判断那个先说话public void run(){  // 覆写run()方法if(flag){synchronized(zs){   // 同步张三zs.say() ;try{Thread.sleep(500) ;}catch(InterruptedException e){e.printStackTrace() ;}synchronized(ls){zs.get() ;}}}else{synchronized(ls){ls.say() ;try{Thread.sleep(500) ;}catch(InterruptedException e){e.printStackTrace() ;}synchronized(zs){ls.get() ;}}}}public static void main(String args[]){ThreadDeadLock t1 = new ThreadDeadLock() ;      // 控制张三ThreadDeadLock t2 = new ThreadDeadLock() ;      // 控制李四t1.flag = true ;t2.flag = false ;Thread thA = new Thread(t1) ;Thread thB = new Thread(t2) ;thA.start() ;thB.start() ;}
};

程序运行结果： 

以下代码不再执行，程序进入死锁状态。