欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

Java并发编程示例(五):线程休眠与恢复

程序员文章站 2024-02-29 23:58:16
有时,我们需要在指定的时间点中断正在执行的线程。比如,每分钟检查一次传感器状态的线程,其余时间,线程不需要做任何事情。在此期间,线程不需要使用计算机的任何资源。过了这段时间...

有时,我们需要在指定的时间点中断正在执行的线程。比如,每分钟检查一次传感器状态的线程,其余时间,线程不需要做任何事情。在此期间,线程不需要使用计算机的任何资源。过了这段时间之后,并且当java虚拟机调度了该线程,则该线程继续执行。为此,你可以使用thread类的sleeep()方法。该方法以休眠的方式来推迟线程的执行,而且整数类型的参数则指明休眠的毫秒数。当调用sleep()方法,休眠时间结束后,java虚拟机分配给线程cpu运行时间,线程就会继续执行。

另一种是用sleep()方法的方式是通过枚举类型timeunit的元素。该方式使用thread的sleep()方法来使得当前线程进行休眠,它可以接受指定单位的时间作为参数,并将这些其转换成对应的毫秒数。

在本节,我们将开发一个程序,使用sleep()方法来实现每秒钟打印一次当前时间。

知其然

按照下面所示步骤,来实现本节示例。

1.创建一个名为fileclock的类,并且实现runnable接口。代码如下:

复制代码 代码如下:

public class fileclock implements runnable {

2.实现run()方法。代码如下:
复制代码 代码如下:

@override
public void run() {

3.写一个遍历十次的循环,在每次迭代中,创建一个date对象,并将其打印到控制台。然后,通过timeutil的seconds属性调用sleep()方法,来延迟一秒钟执行线程。以为sleep()方法会抛出interruptedexception异常。所以,我们需要多写几行代码,用来捕获异常。当线程可能中断是,释放或者关闭在线程中使用的资源,总是最佳实践。代码如下:
复制代码 代码如下:

for (int i = 0; i < 10; i++) {
    system.out.printf("%s\n", new date());
    try {
        timeunit.seconds.sleep(1);
    } catch (interruptedexception e) {
        system.out.printf("the fileclock has been interrupted.\n");
    }
}

4.我们已经有了实现好的线程类。现在,我们来实现主类。创建一个名为filemain的类,并且实现main()方法。代码如下:

复制代码 代码如下:

public class filemain {
    public static void main(string[] args) {

5.创建一个fileclock对象,再创建一个线程用于执行任务。然后,启动线程。代码如下:

复制代码 代码如下:

fileclock clock = new fileclock();
thread thread = new thread(clock);
thread.start();

6.在主线程中,通过timeutil的seconds属性调用sleep()方法,来等待五秒钟。代码如下:
复制代码 代码如下:

try {
    timeunit.seconds.sleep(5);
} catch (interruptedexception e) {
    e.printstacktrace();
}

7.中断fileclock线程。代码如下:

复制代码 代码如下:

thread.interrupt();

8.执行示例,查看执行效果。

知其所以然

当执行这个程序时,会发现,程序如何每秒钟打印一次日期对象,以及线程被中断的情况。

当调用sleep()方法时,线程将离开cpu,并停止执行一段时间。在这段时间内,线程不需要cpu了,所以cpu可以执行其他任务。

当休眠中的线程被中断时,会立即抛出一个interruptedexception,而不是等到休眠结束。

永无止境

java并发api中,还有另外一个方法可以让线程让出cpu。这就是yield()方法,调用该方法就是想java虚拟机发送消息说明线程可以让出cpu给其他线程。java虚拟机并不保证响应这个请求。一般情况下,该方法仅仅在调试程序时使用。

拿来主义

本文是从 《java 7 concurrency cookbook》 (d瓜哥窃译为 《java7并发示例集》 )翻译而来,仅作为学习资料使用。没有授权,不得用于任何商业行为。

小有所成

本节所用的示例代码的完整版。

fileclock类的完整代码

复制代码 代码如下:

package com.diguage.books.concurrencycookbook.chapter1.recipe5;

import java.util.date;
import java.util.concurrent.timeunit;

/**
 * 每秒向控制台打印出当前日期和时间。
 * date: 2013-09-18
 * time: 23:11
 */
public class fileclock implements runnable {
    @override
    public void run() {
        for (int i = 0; i < 10; i++) {
            system.out.printf("%s\n", new date());
            try {
                timeunit.seconds.sleep(1);
            } catch (interruptedexception e) {
                system.out.printf("the fileclock has been interrupted.\n");
            }
        }
    }

filemain类的完整代码

复制代码 代码如下:

package com.diguage.books.concurrencycookbook.chapter1.recipe5;

import java.util.concurrent.timeunit;

/**
 * 演示线程休眠和恢复
 * date: 2013-09-19
 * time: 00:29
 */
public class filemain {
    public static void main(string[] args) {
        fileclock clock = new fileclock();
        thread thread = new thread(clock);
        thread.start();

        try {
            timeunit.seconds.sleep(5);
        } catch (interruptedexception e) {
            e.printstacktrace();
        }

        thread.interrupt();
    }
}