资讯专栏INFORMATION COLUMN

Java™ 教程(Thread对象)

you_De / 2436人阅读

Thread对象

每个线程都与Thread类的实例相关联,使用Thread对象创建并发应用程序有两种基本策略。

要直接控制线程的创建和管理,只需在每次应用程序需要启动异步任务时实例化Thread

要从应用程序的其余部分抽象线程管理,请将应用程序的任务传递给执行器。

本节介绍Thread对象的使用,Executors将与其他高级并发对象一起讨论。

定义和启动线程

创建Thread实例的应用程序必须提供将在该线程中运行的代码,有两种方法可以做到这一点:

提供Runnable对象,Runnable接口定义了一个多带带的run方法,用于包含在线程中执行的代码,Runnable对象被传递给Thread构造函数,如HelloRunnable示例中所示:

public class HelloRunnable implements Runnable {

    public void run() {
        System.out.println("Hello from a thread!");
    }

    public static void main(String args[]) {
        (new Thread(new HelloRunnable())).start();
    }

}

子类化ThreadThread类本身实现了Runnable,尽管它的run方法什么都不做,应用程序可以子类化Thread,提供自己的run实现,如HelloThread示例中所示:

public class HelloThread extends Thread {

    public void run() {
        System.out.println("Hello from a thread!");
    }

    public static void main(String args[]) {
        (new HelloThread()).start();
    }

}

请注意,两个示例都调用Thread.start以启动新线程。

你应该使用哪个语法?使用Runnable对象的第一个语法更通用,因为Runnable对象可以继承Thread以外的类。第二个语法在简单的应用程序中更容易使用,但受限于你的任务类必须是Thread的后代这一事实。本课重点介绍第一种方法,该方法将Runnable任务与执行任务的Thread对象分开,这种方法不仅更灵活,而且适用于后面介绍的高级线程管理API。

Thread类定义了许多对线程管理有用的方法,这些包括静态方法,它们提供关于调用该方法的线程的信息,或影响该线程的状态。其他方法是从管理线程和Thread对象的其他线程调用的,我们将在以下部分中研究其中一些方法。

用Sleep暂停执行

Thread.sleep导致当前线程暂停执行指定的时间段,这是使处理器时间可用于应用程序的其他线程或可能在计算机系统上运行的其他应用程序的有效方法。sleep方法也可以用于调步,如下面的示例所示,和等待具有被理解为具有时间要求的职责的另一个线程,如稍后部分中的SimpleThreads示例。

提供了两个重载版本的sleep:一个指定毫秒的睡眠时间,一个指定纳秒的睡眠时间。但是,这些睡眠时间并不能保证精确,因为它们受到底层操作系统提供的设施的限制,此外,睡眠周期可以通过中断终止,我们将在后面的部分中看到。在任何情况下,你都不能设想调用sleep会准确地在指定的时间段内暂停该线程。

SleepMessages示例使用sleep以四秒为间隔打印消息:

public class SleepMessages {
    public static void main(String args[])
        throws InterruptedException {
        String importantInfo[] = {
            "Mares eat oats",
            "Does eat oats",
            "Little lambs eat ivy",
            "A kid will eat ivy too"
        };

        for (int i = 0;
             i < importantInfo.length;
             i++) {
            //Pause for 4 seconds
            Thread.sleep(4000);
            //Print a message
            System.out.println(importantInfo[i]);
        }
    }
}

请注意,main声明抛出InterruptedException,这是一个异常,当sleep处于活动状态时,另一个线程中断当前线程时,sleep将抛出,由于此应用程序尚未定义另一个导致中断的线程,因此无需捕获InterruptedException

中断

中断是指示线程应该停止正在做的事情,并执行其他操作,由程序员决定线程如何响应中断,但用于终止线程是很常见的,这是本课程中强调的用法。

线程通过调用Thread对象上的interrupt来发送中断,以便线程被中断,为使中断机制正常工作,被中断的线程必须支持自己的中断。

支持中断

线程如何支持自己的中断?这取决于它目前正在做什么,如果线程经常调用抛出InterruptedException的方法,它只会在捕获该异常后从run方法返回。例如,假设SleepMessages示例中的中心消息循环位于线程的Runnable对象的run方法中,然后可以按如下方式修改它以支持中断:

for (int i = 0; i < importantInfo.length; i++) {
    // Pause for 4 seconds
    try {
        Thread.sleep(4000);
    } catch (InterruptedException e) {
        // We"ve been interrupted: no more messages.
        return;
    }
    // Print a message
    System.out.println(importantInfo[i]);
}

许多抛出InterruptedException的方法(例如sleep)被设计为收到中断时取消当前操作并立即返回。

如果一个线程长时间运行而不调用抛出InterruptedException的方法呢?那么它必须定期调用Thread.interrupted,如果收到中断,则返回true,例如:

for (int i = 0; i < inputs.length; i++) {
    heavyCrunch(inputs[i]);
    if (Thread.interrupted()) {
        // We"ve been interrupted: no more crunching.
        return;
    }
}

在这个简单的例子中,代码只是测试中断,如果收到中断则退出线程,在更复杂的应用程序中,抛出InterruptedException可能更有意义:

if (Thread.interrupted()) {
    throw new InterruptedException();
}

这允许中断处理代码集中在catch子句中。

中断状态标志

中断机制使用称为中断状态的内部标志来实现,调用Thread.interrupt设置此标志,当线程通过调用静态方法Thread.interrupted来检查中断时,将清除中断状态,非静态isInterrupted方法,由一个线程用于查询另一个线程的中断状态,不会更改中断状态标志。

按照惯例,任何通过抛出InterruptedException退出的方法都会在执行此操作时清除中断状态,但是,通过另一个线程调用中断,总是可以立即再次设置中断状态。

加入

join方法允许一个线程等待另一个线程的完成,如果t是其线程当前正在执行的Thread对象:

t.join();

导致当前线程暂停执行,直到t的线程终止,join重载方法允许程序员指定等待周期,但是,与sleep一样,join依赖于OS进行计时,因此你不应该设想join将准确地等待你指定的时间。

sleep一样,join通过InterruptedException退出来响应中断。

SimpleThreads示例

以下示例汇总了本节的一些概念,SimpleThreads由两个线程组成。第一个是每个Java应用程序都有的主线程,主线程从Runnable对象MessageLoop创建一个新线程,并等待它完成,如果MessageLoop线程需要很长时间才能完成,主线程会中断它。

MessageLoop线程打印出一系列消息,如果在打印完所有消息之前被中断,MessageLoop线程将打印一条消息并退出。

public class SimpleThreads {

    // Display a message, preceded by
    // the name of the current thread
    static void threadMessage(String message) {
        String threadName =
            Thread.currentThread().getName();
        System.out.format("%s: %s%n",
                          threadName,
                          message);
    }

    private static class MessageLoop
        implements Runnable {
        public void run() {
            String importantInfo[] = {
                "Mares eat oats",
                "Does eat oats",
                "Little lambs eat ivy",
                "A kid will eat ivy too"
            };
            try {
                for (int i = 0;
                     i < importantInfo.length;
                     i++) {
                    // Pause for 4 seconds
                    Thread.sleep(4000);
                    // Print a message
                    threadMessage(importantInfo[i]);
                }
            } catch (InterruptedException e) {
                threadMessage("I wasn"t done!");
            }
        }
    }

    public static void main(String args[])
        throws InterruptedException {

        // Delay, in milliseconds before
        // we interrupt MessageLoop
        // thread (default one hour).
        long patience = 1000 * 60 * 60;

        // If command line argument
        // present, gives patience
        // in seconds.
        if (args.length > 0) {
            try {
                patience = Long.parseLong(args[0]) * 1000;
            } catch (NumberFormatException e) {
                System.err.println("Argument must be an integer.");
                System.exit(1);
            }
        }

        threadMessage("Starting MessageLoop thread");
        long startTime = System.currentTimeMillis();
        Thread t = new Thread(new MessageLoop());
        t.start();

        threadMessage("Waiting for MessageLoop thread to finish");
        // loop until MessageLoop
        // thread exits
        while (t.isAlive()) {
            threadMessage("Still waiting...");
            // Wait maximum of 1 second
            // for MessageLoop thread
            // to finish.
            t.join(1000);
            if (((System.currentTimeMillis() - startTime) > patience)
                  && t.isAlive()) {
                threadMessage("Tired of waiting!");
                t.interrupt();
                // Shouldn"t be long now
                // -- wait indefinitely
                t.join();
            }
        }
        threadMessage("Finally!");
    }
}
上一篇:进程和线程 下一篇:同步

文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。

转载请注明本文地址:https://www.ucloud.cn/yun/72993.html

相关文章

  • [译] Java 8 Nashorn 教程

    摘要:未来的主要发布基于。在中调用函数支持从代码中直接调用定义在脚本文件中的函数。下面的函数稍后会在端调用为了调用函数,你首先需要将脚本引擎转换为。调用函数将结果输出到,所以我们会首先看到输出。幸运的是,有一套补救措施。 原文:Java 8 Nashorn Tutorial 译者:飞龙 协议:CC BY-NC-SA 4.0 这个教程中,你会通过简单易懂的代码示例,来了解Nashorn Ja...

    _ivan 评论0 收藏0
  • Java 8 并发教程:线程和执行器

    摘要:在这个示例中我们使用了一个单线程线程池的。在延迟消逝后,任务将会并发执行。这是并发系列教程的第一部分。第一部分线程和执行器第二部分同步和锁第三部分原子操作和 Java 8 并发教程:线程和执行器 原文:Java 8 Concurrency Tutorial: Threads and Executors 译者:BlankKelly 来源:Java8并发教程:Threads和Execut...

    jsdt 评论0 收藏0
  • Java教程(Lock对象

    Lock对象 同步代码依赖于简单的可重入锁,这种锁易于使用,但有许多限制,java.util.concurrent.locks包支持更复杂的锁定语法,我们不会详细检查这个包,而是将重点放在其最基本的接口Lock上。 Lock对象的工作方式与同步代码使用的隐式锁定非常相似,与隐式锁一样,一次只有一个线程可以拥有一个Lock对象,Lock对象还通过其关联的Condition对象支持wait/notif...

    RobinQu 评论0 收藏0
  • Java精讲:生产者-消费者

    摘要:创建一个阻塞队列生产者生产,目前总共有消费者消费,目前总共有原文链接更多教程 原文链接 更多教程 本文概要 生产者和消费者问题是线程模型中老生常谈的问题,也是面试中经常遇到的问题。光在Java中的实现方式多达数十种,更不用说加上其他语言的实现方式了。那么我们该如何学习呢? 本文会通过精讲wait()和notify()方法实现生产者-消费者模型,来学习生产者和消费者问题的原理。 目的...

    VPointer 评论0 收藏0

发表评论

0条评论

最新活动
阅读需要支付1元查看
<