Java使用线程池执行定时任务

使用线程池执行定时任务是提高 Java 程序性能的重要手段之一。下面就来详细讲解 Java 使用线程池执行定时任务的完整攻略。

1. 什么是线程池？

线程池是一种线程管理机制，它主要解决两个问题：线程复用和线程管理。线程池中维护了一组已经创建好的线程，供我们执行任务，这样就避免了每次执行任务都需要创建和销毁线程的开销。

2. Java 如何使用线程池执行定时任务？

Java 使用线程池执行定时任务主要分为以下几个步骤：

2.1 创建线程池

Java 中使用 java.util.concurrent.Executors 类的静态方法来创建线程池，示例如下：

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class ThreadPoolDemo {
    public static void main(String[] args) {
        ExecutorService executorService = Executors.newFixedThreadPool(10);
        // do something
        executorService.shutdown();
    }
}

这里我们使用 Executors.newFixedThreadPool() 方法创建了一个线程个数为 10 的线程池。

2.2 创建定时任务

Java 中使用 java.util.concurrent.Executors 类的 schedule() 方法来创建定时任务，示例如下：

executorService.schedule(new Runnable() {
    @Override
    public void run() {
        System.out.println("定时任务执行");
    }
}, 5, TimeUnit.SECONDS);

这里我们将定时任务设置为 5 秒执行一次，定时任务的具体操作就是打印一句话。

2.3 关闭线程池

在完成任务后，我们需要关闭线程池来释放资源，Java 中使用 shutdown() 方法来关闭线程池。

3. 示例说明

下面给出两个 Java 使用线程池执行定时任务的示例代码：

示例 1

import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

public class ScheduledThreadPool {

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

        Runnable task = new Runnable() {
            public void run() {
                System.out.println("Run ScheduledThreadPool");
            }
        };
        ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);
        scheduler.scheduleWithFixedDelay(task, 0, 1, TimeUnit.SECONDS);
        Thread.sleep(10000);
        scheduler.shutdown();
    }
}

这个示例中创建了只有一个线程的 ScheduledExecutorService 对象 scheduler，并用它来定时执行 task，每个任务执行的间隔时间为1秒。

示例 2

import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

public class ScheduledThreadPool2 {

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

        Runnable task = new Runnable() {
            public void run() {
                System.out.println("Run ScheduledThreadPool2");
            }
        };
        ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);
        scheduler.scheduleAtFixedRate(task, 0, 1, TimeUnit.SECONDS);
        Thread.sleep(10000);
        scheduler.shutdown();
    }
}

这个示例中同样创建了只有一个线程的 ScheduledExecutorService 对象 scheduler，并用它来定时执行 task，每个任务执行的间隔时间也为1秒，不同的是这个示例使用的是 scheduleAtFixedRate() 方法，与示例1中的scheduleWithFixedDelay() 不同，这个方法会在固定既定时间内不断执行相同任务。

以上是Java使用线程池执行定时任务的完整攻略及示例代码。