1-1.3.线程终止

不正确的线程终止--Stop

Stop:终止线程,并且清除监控器锁的信息,但是可能导致线程安全问题JDK不建议用

Destroy: JDK未实现该方法

stop命令之后,可能线程从中执行一半就折断了,执行了一般,数据不一致,存在线程安全的问题

举例:结果打印:i =1,j=0--->错误

public class StopThread extends Thread {
  private int i = 0, j = 0;
  @Override
  public void run() {
    synchronized (this) {
        // 增加同步锁,确保线程安全
        ++i;
        try {
          // 休眠10秒,模拟耗时操作
          Thread.sleep(10000);
        } catch (InterruptedException e) {
          e.printStackTrace();
        }
        ++j;
    }
  }
  /** * 打印i和j */
  public void print() {
  System.out.println("i=" + i + " j=" + j);
  }
}
/**
 * 示例3 - 线程stop强制性中止,破坏线程安全的示例
 */
public class Demo3 {
  public static void main(String[] args) throws InterruptedException {
    StopThread thread = new StopThread();
    thread.start();
    // 休眠1秒,确保i变量自增成功
    Thread.sleep(1000);
    // 暂停线程
    thread.stop(); // 错误的终止
    while (thread.isAlive()) {
      // 确保线程已经终止
    } // 输出结果
    thread.print();
  }
}

正确的线程终止 -interrupt

如果目标线程在调用Object的wait()/wait(long)/wait(long,int)方法,join()/join(long,int)或者sleep(long,int)方法时被阻塞,那么Interrupt会生效,该线程的中断状态将被清除,抛出InterruptedException异常。

如果目标线程被I/O或者NIO中的Channel所阻塞,同样,I/O操作会被中断或者返回特殊异常值。达到终止线程的目的。

如果以上都不满足,则会设置此线程的终止状态

将thread.stop(); 替换成 thread.interrupt(); // 正确终止 ==>结果打印异常,同时打印结果:i=1,j=1

正确的线程终止 -标志位

代码逻辑中,增加一个判断(boolean flag),用来控制线程执行的终止

/** 通过状态位来判断 */
public class Demo4 extends Thread {
  public volatile static boolean flag = true;

  public static void main(String[] args) throws InterruptedException {
    new Thread(() -> {
      try {
        while (flag) { // 判断是否运行
          System.out.println("运行中");
          Thread.sleep(1000L);
        }
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
    }).start();
    // 3秒之后,将状态标志改为False,代表不继续运行
    Thread.sleep(3000L);
    flag = false;
    System.out.println("程序运行结束");
  }
}
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。