前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >一个线程调用两次 start()方法会出现什么情况?

一个线程调用两次 start()方法会出现什么情况?

作者头像
王小明_HIT
发布2020-05-08 18:10:37
1.9K0
发布2020-05-08 18:10:37
举报
文章被收录于专栏:程序员奇点程序员奇点

一个线程两次调用 start 会出现什么情况?

一个线程两次调用 start()方法会出现什么情况?谈谈线程的生命周期和状态转移。在第二次调用 start() 方法的时候,线程可能处于终止或者其他(非NEW)状态,但是不论如何,都是不可以再次启动的。

调用两次 start ?

Java的线程是不允许启动两次的,第二次调用必然会抛岀 IllegalThreadStateEXception,这是一种运行时异常,多次调用 start 被认为是编程错误。

线程的生命周期

关于线程生命周期的不同状态,在Java5以后,线程状态被明确定义在其公共内部枚举类型java.ang. Thread. State中,分别是:

  • 新建(NEW),表示线程被创建出来还没真正启动的状态,可以认为它是个Java内部状态。
  • 就绪( RUNNABLE),表示该线程已经在wM中执行,当然由于执行需要计算资源,它可能是正在运行,也可能还在等待系统分配给它CP∪片段,在就绪队列里面排队。
  • 运行(Running)在其他一些分析中,会额外区分一种状态 RUNNING,但是从 Java aPi的角度,并不能表示出来。
  • 阻塞( BLOCKED),这个状态和我们前面两讲介绍的同步非常相关,阻塞表示线程在等待 Monitor lock。比如,线程试图通过synchronized去获取某个锁,但是其他线程已经独占了,那么当前线程就会处于阻塞状态。
  • 等待( WAITING),表示正在等待其他线程釆取某些操作。一个常见的场景是类似生产者消费者模式,发现任务条件尚未满足,就让当前消费者线程等待(wait),另外的生产者线程去准备任务数据,然后通过类似 notify等动作,通知消费线程可以继续工作了。Thread join(也会令线程进入等待状态。
  • 计时等待( TIMED_WAIT),其进入条件和等待状态类似,但是调用的是存在超时条件的方法,比如wait或join等方法的指定超时版本,如下面示例
代码语言:javascript
复制
public final native void wait(long timeout) throws InterruptedException;
  • 终止( TERMINATED),不管是意外退出还是正常执行结束,线程已经完成使命,终止运行,也有人把这个状态叫作死亡在第二次调用 start()方法的时候,线程可能处于终止或者其他(非NEW)状态,但是不论如何,都是不可以再次启动的。

线程状态转换图

线程是什么?

从操作系统的角度,可以简单认为,线程是系统调度的最小单元,一个进程可以包含多个线程,作为任务的真正运作者,有自己的栈( Stack)、寄存器( Register)、本地存储 ( Thread Local)等,但是会和迸程内其他线程共享文件描述符、虚拟地址空间等

线程的分类

在具体实现中,线程还分为内核线程用户线程,Java的线程实现其实是与虚拟机相关的。对于我们最熟悉的sun/ Oracle jDK,其线程也经历了一个演进过程,基本上在Java1.2之后,JDK已经抛弃了所谓的 Green Thread,也就是用户调度的线程,现在的模型是一对一映射到操作系统内核线程。

  • https://en.wikipedia.org/wiki/Green_threads

Thread 源码

Thread 源码中大部分逻辑是直接调用 JNI 本地代码。

代码语言:javascript
复制
private native void start0();
private native void setPriority0 (int newPriority);
private native void interrupt0()
  1. 优点 这种直接调用 JNI 形式的本地代码能精细的控制线程和相关的并发操作,并且拥有高扩展能力。
  2. 缺点 实现复杂,提高了并发编程的门槛。

线程的基本操作

新建线程

代码语言:javascript
复制
  Runnable task =()->System.out.println("Hello World!");
  Thread myThread = new Thread(task);
  myThread.start();
  myThread.join();

直接扩展 Thread 类,然后实例化,上面的例子中, 实现一个 Runnable,将代码逻辑放在 Runnable 中,然后使用 Thread 并启动 start ,等待 join 结束。Runnable 的好处是,不会有多继承的限制,重用代码实现,可以实现重复逻辑。并且能够更好的结合 Java 并发库中的 Executor 框架使用。比如将上面的start,join 可以改写成下面的代码:

代码语言:javascript
复制
Runnable task =()->System.out.println("Hello World!");
Future future = (Future) Executors.newFixedThreadPool(1).submit(task).get();

使用上面的方式,可以不用操心线程的创建和管理。

哪些因素可能影响线程的状态

线程自身的方法

除了 start 之外,还有多个 join 方法等待线程结束。yield 告诉调度器,主动让出 CPU, 另外, 还有些过时方法 resume, stop, suspend,destroy ,stop。

基类 Object 中提供一些基础的 wait/notify/notifyAll方法。

如果我们持有某个对象的某个 Monitor锁,调用 wait 会让当前线程处于等待状态。直到其他线程 notify 或者 notifyAll。本质上是提供了 Monitor 的释放和获取能力。

并发类库中的工具

比如 CountDownLatch.await() 会让线程进入等待状态,知道 latch 基数为0 ,就可以看做是线程间的通讯 Signal.

image

Thread 和 Object 方法 进行线程之间的调度和维护,比较晦涩难懂,一般使用 Java 并发包进行线程的使用。

守护线程

守护线程(Daemon Thread),需要一个长期驻留服务的程序,但是不希望其影响应用退出,就可以设置成守护线程。

代码语言:javascript
复制
Thread daemonThread = new Thread();
daemonThread.setDaemon(true)
daemonThread.start()

再来看看 Spurious wakeuρ。尤其是在多核CP∪的系统中,线程等待存在一种可能,就是在没有仼何线程广播或者发岀信号的情况下,线程就被唤醒,如果处理不当就可能岀现诡异的并发问题,所以我们在等待条件过程中,建议采用下面模式来书写。

  • https://en.wikipedia.org/wiki/Spurious_wakeup
代码语言:javascript
复制
//推荐
while(isConditiono())){
   waitForAConfition()
}
//不推荐,可能引入bug
if(isCondition()){
   waitForAConfition();
}

ThreadLocal

ThreadLocal 内部条目是弱引用, ThreadLocalMap里面的数据存储结构,从上面的代码来看,ThreadLocalMap中存放的就是Entry,Entry的KEY就是ThreadLocal,VALUE就是值。在ThreadLocal的get,set的时候都会清除线程Map里所有key为null的value。但是如果不调用 get set 的话,value不会被清理,就存在内存泄露.

代码语言:javascript
复制
static class ThreadLocalMap {
    Object value;
    Entry(ThreadLocal<?> k, Object v) {
        super(k);
        value = v;
    }
}

set 方法

代码语言:javascript
复制
private void set(ThreadLocal<?> key, Object value) {

            Entry[] tab = table;
            int len = tab.length;
            int i = key.threadLocalHashCode & (len-1);

            for (Entry e = tab[i];
                 e != null;
                 e = tab[i = nextIndex(i, len)]) {
                ThreadLocal<?> k = e.get();

                if (k == key) {
                    e.value = value;
                    return;
                }

                if (k == null) {
                    // 替换废弃条目
                    replaceStaleEntry(key, value, i);
                    return;
                }
            }

            tab[i] = new Entry(key, value);
            int sz = ++size;
            // 扫码并清理发现的废弃条目,并检查容量是否超限
            if (!cleanSomeSlots(i, sz) && sz >= threshold)
                rehash();// 清理废弃条目,如果超限,则扩容
        }
本文参与 腾讯云自媒体分享计划,分享自微信公众号。
原始发表:2020-05-02,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 程序员奇点 微信公众号,前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体分享计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 一个线程两次调用 start 会出现什么情况?
    • 调用两次 start ?
      • 线程的生命周期
        • 线程是什么?
          • 线程的分类
            • Thread 源码
              • 线程的基本操作
                • 新建线程
              • 哪些因素可能影响线程的状态
                • 线程自身的方法
                • 基类 Object 中提供一些基础的 wait/notify/notifyAll方法。
                • 并发类库中的工具
                • 守护线程
              • ThreadLocal
              相关产品与服务
              数据保险箱
              数据保险箱(Cloud Data Coffer Service,CDCS)为您提供更高安全系数的企业核心数据存储服务。您可以通过自定义过期天数的方法删除数据,避免误删带来的损害,还可以将数据跨地域存储,防止一些不可抗因素导致的数据丢失。数据保险箱支持通过控制台、API 等多样化方式快速简单接入,实现海量数据的存储管理。您可以使用数据保险箱对文件数据进行上传、下载,最终实现数据的安全存储和提取。
              领券
              问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档