ScheduledThreadPoolExecutor 類

java.util.concurrent.ScheduledThreadPoolExecutor 是 ThreadPoolExecutor 的一個子類，此外還可以排程命令在給定延遲後執行，或定期執行。

ScheduledThreadPoolExecutor 方法

序號	方法及描述
1	protected <V> RunnableScheduledFuture<V> decorateTask(Callable<V> callable, RunnableScheduledFuture<V> task) 修改或替換用於執行可呼叫的任務。
2	protected <V> RunnableScheduledFuture<V> decorateTask(Runnable runnable, RunnableScheduledFuture<V> task) 修改或替換用於執行可執行的任務。
3	void execute(Runnable command) 以零所需延遲執行命令。
4	boolean getContinueExistingPeriodicTasksAfterShutdownPolicy() 獲取關於即使在此執行程式已關閉後是否繼續執行現有定期任務的策略。
5	boolean getExecuteExistingDelayedTasksAfterShutdownPolicy() 獲取關於即使在此執行程式已關閉後是否執行現有延遲任務的策略。
6	BlockingQueue<Runnable> getQueue() 返回此執行程式使用的任務佇列。
7	boolean getRemoveOnCancelPolicy() 獲取關於取消的任務是否應在取消時立即從工作佇列中刪除的策略。
8	<V> ScheduledFuture<V> schedule(Callable<V> callable, long delay, TimeUnit unit) 建立並執行一個 ScheduledFuture，該 Future 在給定延遲後啟用。
9	ScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) 建立並執行一個一次性操作，該操作在給定延遲後啟用。
10	ScheduledFuture<?> scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit) 建立並執行一個定期操作，該操作首先在給定的初始延遲後啟用，然後以給定的週期啟用；也就是說，執行將在 initialDelay 後開始，然後是 initialDelay+period，然後是 initialDelay + 2 * period，依此類推。
11	ScheduledFuture<?> scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit) 建立並執行一個定期操作，該操作首先在給定的初始延遲後啟用，然後在一次執行終止與下一次執行開始之間以給定的延遲啟用。
12	void setContinueExistingPeriodicTasksAfterShutdownPolicy (boolean value) 設定關於即使在此執行程式已關閉後是否繼續執行現有定期任務的策略。
13	void setExecuteExistingDelayedTasksAfterShutdownPolicy (boolean value) 設定關於即使在此執行程式已關閉後是否執行現有延遲任務的策略。
14	void setRemoveOnCancelPolicy(boolean value) 設定關於取消的任務是否應在取消時立即從工作佇列中刪除的策略。
15	void shutdown() 啟動有序關閉，其中先前提交的任務將被執行，但不會接受新任務。
16	List<Runnable> shutdownNow() 嘗試停止所有正在積極執行的任務，停止等待任務的處理，並返回正在等待執行的任務列表。
17	<T> Future<T> submit(Callable<T> task) 提交一個返回值任務以供執行，並返回一個 Future，該 Future 代表任務的待處理結果。
18	Future<?> submit(Runnable task) 提交一個 Runnable 任務以供執行，並返回一個 Future，該 Future 代表該任務。
19	<T> Future<T> submit(Runnable task, T result) 提交一個 Runnable 任務以供執行，並返回一個 Future，該 Future 代表該任務。

示例

以下 TestThread 程式顯示了在基於執行緒的環境中使用 ScheduledThreadPoolExecutor 介面。

線上演示

import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.TimeUnit;

public class TestThread {

   public static void main(final String[] arguments) throws InterruptedException {
      final ScheduledThreadPoolExecutor scheduler = 
         (ScheduledThreadPoolExecutor)Executors.newScheduledThreadPool(1);

      final ScheduledFuture<?> beepHandler = 
         scheduler.scheduleAtFixedRate(new BeepTask(), 2, 2, TimeUnit.SECONDS);

      scheduler.schedule(new Runnable() {

         @Override
         public void run() {
            beepHandler.cancel(true);
            scheduler.shutdown();			
         }
      }, 10, TimeUnit.SECONDS);
   }  

   static class BeepTask implements Runnable {
      
      public void run() {
         System.out.println("beep");      
      }
   }
}

這將產生以下結果。

輸出

beep
beep
beep
beep

列印頁面

上一個

下一個