当前位置: 代码迷 >> Java面试 >> Java面试有关问题之四十七
  详细解决方案

Java面试有关问题之四十七

热度:68   发布时间:2016-04-17 18:28:16.0
Java面试问题之四十七
请问如何才能安全地使线程暂停、恢复运行和停止,谈谈你的想法并举例说明。

答:虽然在Java中的Thread类中分别提供了使线程暂停(suspend()方法)、恢复运行(resume()方法)以及停止(stop()方法)的方法,但是使用这些方法会产生如下两点风险:
(1)容易造成死锁。
(2)一个线程强制中断另一个线程的运行,会造成另一个线程操作的数据停留在逻辑上不合理
       的状态。
  基于上述的原因,Thread类中直接控制线程暂停、恢复和停止的方法已经在JDK 1.2版本之后
  被抛弃(Deprecated)。在实际编程中,一般是在受控制的线程中定义一个标志变量,其他线
  程通过改变标志变量的值,来控制线程的暂停、恢复运行和自然终止。比如,我们可以定义一
  个可控的线程类ControlledThread,它有一个state属性来控制它的状态:
   ? SUSP:暂停状态,线程进入当前线程对象的等待池。
   ? STOP:终止状态,线程会自然退出run()方法。
   ? RUN:运行状态,线程可以继续运行。
  MachineControlledThread类继承ControlledThread类,因此MachineControlledThread是
  受控制的线程。在MachineControlledThread类的run()方法的while循环中,每次循环结束前 
  都会调用checkState()方法,判断接下来到底是继续运行、还是暂停或者终止运行。

  主线程通过调用MachineControlledThread对象的setState()方法来控制
  MachineControlledThread线程。当MachineControlledThread对象的实例变量count的
  值大于5时,就让MachineControlledThread线程暂停,把MachineControlledThread对
  象的实例变量count设为0,然后在使MachineControlledThread线程恢复运行。主线程最
  后终止MachineControlledThread线程的运行。

 
  class ControlledThread extends Thread {        public static final int SUSP=1;        public static final int STOP=2;        public static final int RUN=0;        private int state = RUN;        public synchronized void setState(int state){                this.state = state;                if(state == RUN){                        notify();                }        }        public synchronized boolean checkState() {                while(state == SUSP){                        try {                                System.out.println(Thread.currentThread().getName() + ":wait");                                wait();                        }catch(InterruptedException e){                                throw new RuntimeException(e.getMessage());                        }                }                if(state == STOP){                        return false;                }                return true;        }}public class MachineControlledThread extends ControlledThread {        private int count;        public void run() {                while(true){                        synchronized(this) {                                count++;                                System.out.println(Thread.currentThread().getName()+":run "+count+" times");                        }                        if(!checkState()){                                System.out.println(Thread.currentThread().getName()+":stop"); break;                        }                }        }        public synchronized int getCount() {return count;}        public synchronized void reset() {                count=0;                System.out.println(Thread.currentThread().getName()+":reset");        }        public static void main(String[] args) {                MachineControlledThread machine = new MachineControlledThread();                machine.start();                for(int i=0;i<30;i++){                        if(machine.getCount()>5) {                                machine.setState(ControlledThread.SUSP);                                yield();                                machine.reset();                                machine.setState(ControlledThread.RUN);                        }                        yield();                }                machine.setState(ControlledThread.STOP);        }}  



  值得注意的是,上述代码对线程的控制并不是实时的,当主线程在某个时刻执行了
  machine.setState(ControlledThread.SUSP)方法时,machine线程并不会立刻进入暂停状
  态。machine线程必须获得CPU,开始执行checkState()方法时,才会进入暂停状态。






  相关解决方案