`
wj416073
  • 浏览: 3661 次
最近访客 更多访客>>
文章分类
社区版块
存档分类
最新评论

[JDK]从Thread.stop到线程取消

阅读更多
         Thread.stop不推荐用了,原因javadoc上给出的链接里面有。大概来讲,是stop会抛出ThreadDeath异常(准确讲是Error),而抛出异常的方法会释放锁(release monitor),其它方法就会访问到本来被锁保护的对象,而这些对象可能处于不一致的状态(没锁保护,但被多线程访问),导致产生不可预知的结果。关键是这种现象很难被观察到,也很难找到原因(根据一个现象,很难发现是stop导致的问题)。很难观察到,是因为它可能有很长的潜伏期,几天之后才会出问题,所谓的“偶发现象”,不能在短时间重现。
        所以一般建议改写run方法,将它用while包起来,while里面判断一个(或若干)状态,再写一个cancle方法取消(或停止)线程,这个cancle会简单,改一下状态就行了。
    private volatile Thread blinker;

    public void stop() {
        blinker = null;
    }

    public void run() {
        Thread thisThread = Thread.currentThread();
        while (blinker == thisThread) {
            try {
                thisThread.sleep(interval);
            } catch (InterruptedException e){
            }
            repaint();
        }
    }

只是要注意一下状态的同步(使用volatile或其它同步方式)
        但java并发编程中,大师发现了这种模式的一个问题,如果while中的动作会阻塞,那么while可能很长时间或永远不会退出。
public void run() {
    try {
        while(!canceled) {
            blockingQueue.put(produceLongTimeJob());
        }
    } catch (InterruptedException ex) {
        /* 允许线程退出 */
    }
}

使用生产者消费者模式,生产者快于消费者,任务队列已经饱和,再调用阻塞队列的put方法就会阻塞,此时只要消费者没有消费任务,整个工作就不会停止,即使调用了停止方法去更改了canceled的状态。
        解决方法java并发编程中也给出了,使用中断。“中断通常是实现取消最明智的选择”。
public void run() {
    try {
        while(!Thread.currentThread().isInterrupted()) {
            blockingQueue.put(produceLongTimeJob());
        }
    } catch (InterruptedException ex) {
        /* 允许线程退出 */
    }
}

这种写法只是加快了中断检测,在生产任务之前如果检测到中断就可以直接退出。其实有try,catch检测中断,逻辑上就可以使用中断来退出了。
        在concurrent包里面,ThreadExecute的工作线程的run方法就是使用while检查状态
public void run() {
    try {
        Runnable task = firstTask;
        firstTask = null;
        while (task != null || (task = getTask()) != null) {
            runTask(task);
            task = null;
        }
    } finally {
        workerDone(this);
    }
}

而在getTask方法中就包括使用中断去通知线程退出
    Runnable getTask() {
        for (;;) {
            try {
                int state = runState;
                if (state > SHUTDOWN)
                    return null;
                Runnable r;
                if (state == SHUTDOWN)  // Help drain queue
                    r = workQueue.poll();
                else if (poolSize > corePoolSize || allowCoreThreadTimeOut)
                    r = workQueue.poll(keepAliveTime, TimeUnit.NANOSECONDS);
                else
                    r = workQueue.take();
                if (r != null)
                    return r;
                if (workerCanExit()) {
                    if (runState >= SHUTDOWN) // Wake up others
                        interruptIdleWorkers();
                    return null;
                }
                // Else retry
            } catch (InterruptedException ie) {
                // On interruption, re-check runState
            }
        }
    }

interruptIdleWorkers()会中断没做事的工作线程,工程线程检测到中断就会退出。
        所以在多线程编程中,一定要处理中断,因为它很常见,而且为了线程能很好的处理退出,也要处理中断,原因上面讲了。
0
0
分享到:
评论

相关推荐

    java解惑--异常地危险

    在JDK1.2中,Thread.stop、Thread.suspend以及其他许多线程相关的方法都因为它们不安全而不推荐使用了。下面的方法展示了你用Thread.stop可以实现的可怕事情之一

    JAVA核心知识点整理(有效)

    1:eden、servicorFrom 复制到 ServicorTo,年龄+1................................................................................... 25 2:清空 eden、servicorFrom.............................................

    java7源码-thread:多线程相关的学习

    Stop:终止线程,并且清除监视器锁的信息,但是可能导致线程安全问题,JDK不建议使用。 代码:Demo02 正确的线程中止-interrupt 如果目标线程在调用Object class的wait()、wait(long)或wait(long millis, int nanos)...

    java线程池概念.txt

    如果继续添加任务到线程池,且线程池中的线程数已经达到了maximumPoolSize,那么线程就会就会执行reject操作(这里后面会提及到) keepAliveTime:表示线程没有任务执行时最多保持多久时间会终止;默认情况下,只有...

    JAVA面试题最全集

    如何取得从1970年到现在的毫秒数 如何获取某个日期是当月的最后一天 如何格式化日期 5.数组和集合 6.文件和目录(I/O)操作 如何列出某个目录下的所有文件 如何列出某个目录下的所有子目录 判断一个文件或...

    超级有影响力霸气的Java面试题大全文档

    sleep是线程类(Thread)的方法,导致此线程暂停执行指定时间,给执行机会给其他线程,但是监控状态依然保持,到时后会自动恢复。调用sleep不会释放对象锁。 wait是Object类的方法,对此对象调用wait方法导致本线程...

    java编程基础,应用与实例

    1.2.5 线程(thread) 2 1.2.6 垃圾回收机制(garbage collection) 2 1.3 安装Java程序开发工具(JDK1.5) 2 1.3.1 安装JAVA 2 Standard Edition 1.5.0 3 1.3.2 安装开发文档及最终完成 5 1.3.3 Java开发工具...

    java 面试题 总结

    sleep是线程类(Thread)的方法,导致此线程暂停执行指定时间,给执行机会给其他线程,但是监控状态依然保持,到时后会自动恢复。调用sleep不会释放对象锁。 wait是Object类的方法,对此对象调用wait方法导致本线程...

    Java面试宝典2020修订版V1.0.1.doc

    9、线程currentThread()与interrupt()方法的使用 59 10、线程状态 59 启动线程的方式?start or run? 59 11、什么是java序列化,如何实现java序列化? 59 12、编写一个程序,将d:\java目录下的所有.java文件复制到d:...

    JVM参数设置详细说明

    CMS gc很少发生,每次时间在init-mark和remark(two steps stop all app thread)总共平均花费80-90ms左右。 在这里我们曾经New Generation调大到1400m,总共2g的jvm heap,平均每次ygc花费时间60-70ms左右,CMS gc...

    千方百计笔试题大全

    218、如何取得从1970年到现在的毫秒数 53 219、如何格式化日期 53 220、文件和目录(I/O)操作 54 230、J2EE的优越性 54 231、Java语言的11个关键特性. 54 232、说出Servlet的生命周期,并说出Servlet和CGI的区别。 ...

    JAVA基础课程讲义

    线程状态和sleep/yield/join/stop/destroy方法 170 新生状态 170 就绪状态 170 运行状态 170 死亡状态 170 终止线程的典型方法(重要!!!) 171 阻塞状态(sleep/yield/join方法) 171 线程基本信息和优先级别 173 ...

    java面试宝典

    218、如何取得从1970年到现在的毫秒数 53 219、如何格式化日期 53 220、文件和目录(I/O)操作 54 230、J2EE的优越性 54 231、Java语言的11个关键特性. 54 232、说出Servlet的生命周期,并说出Servlet和CGI的区别。 ...

Global site tag (gtag.js) - Google Analytics