電子發燒友App
定時/計劃功能在Java應用的各個領域都使用得非常多，比方說Web層面，可能一個項目要定時采集話單、定時更新某些緩存、定時清理一批不活躍用戶等等。定時計劃任務功能在Java中主要使用的就是Timer對象，它在內部使用多線程方式進行處理，所以它和多線程技術關聯還是相當大的。
一、相關知識學習
1、 Java定時器Timer
用于Java線程里指定時間或周期運行任務。Timer是線程安全的，但不提供實時性（real-time）保證。
schdule方法：
schedule（TimerTask task， long delay）
以當前時間為基準，延遲指定的毫秒后執行一次TimerTask任務。
schedule（TimerTask task， Date time）
在指定的日期執行一次TimerTask任務。
如果日期time早于當前時間，則立刻執行。
schedule（TimerTask task， long delay， long period）
以當前時間為基準，延遲指定的毫秒后，再按指定的時間間隔地無限次數的執行TimerTask任務。
schedule（TimerTask task， Date firstTime， long period）
在指定的日期之后，按指定的時間間隔地無限次數的執行TimerTask任務。
scheduleAtFixedRate方法：
scheduleAtFixedRate（TimerTask task， long delay， long period）
以當前時間為基準，延遲指定的毫秒后，再按指定的時間間隔周期性地無限次數的執行TimerTask任務。
如果日期firstTime早于當前時間，則立刻執行，且不執行在時間差內的任務。
scheduleAtFixedRate（TimerTask task， Date firstTime， long period）
在指定的日期之后，按指定的時間間隔周期性地無限次數的執行TimerTask任務。
如果日期firstTime早于當前時間，則立即執行，并補充性的執行在時間差內的任務。
2、 Java多線程學習
在java中要想實現多線程，有兩種手段，一種是繼續Thread類，另外一種是實現Runable接口。
java多線程之繼承Thread類創建線程類的步驟如下：
1.創建Thread類的子類，并重寫run（）方法。
2.創建Thread子類的實例即線程對象3.調用線程對象的start（）方法
3.調用線程對象的start（）方法
Thread類有以下常用構造方法：
1.Thread（）
2.Thread（String name）
3.Thread（Runnable r）
4.Thread（Runnable r，String name）
使用Thread類創建線程類，多個線程之間無法共享線程類的實例變量。
實現Runnable接口比繼承Thread類所具有的優勢：
1.適合多個相同的程序代碼的線程去處理同一個資源
2.可以避免java中的單繼承的限制
3.增加程序的健壯性，代碼可以被多個線程共享，代碼和數據獨立
4.線程池只能放入實現Runable或callable類線程，不能直接放入繼承Thread的類
二、訓練
1、完成一個java application應用程序，使用定時器編程，在實時顯示當前時間，每1秒時鐘內容更新一次。
java程序（test1.java）
import java.util.*;//導入java.util包下的所有類
public class test1 {
private static Timer timer = new Timer（）;//創建一個Timer類的實例
public static class MyTask extends TimerTask {//創建一個MyTask類繼承于父類TimerTask
@Override
public void run（） {
System.out.println（“Now Time： ” + new Date（）.toString（））;//輸出當前時間信息
}
}
public static void main（String［］ args） {
MyTask task = new MyTask（）;
timer.schedule（task， 0， 1000）;//以當前基準時間延遲0秒后執行一次，以后按指定間隔時間1秒無限次數的執行。
}
}
運行效果圖
2、完成一個java application應用程序，在應用程序主進程中新開一個線程，此線程進行死循環，每1秒被激活一次，激活時即在輸出顯示當前時間。
java程序（test2.java）
import java.util.*;//導入java.util包下的所有類
public class test2 {
public static void main（String［］ args） {
FirstThread a=new FirstThread（）;//創建一個FirstThread類對象
a.start（）;//開啟線程
}
}
class FirstThread extends Thread{//創建Thread子類
public void run（）{
try{//異常處理
while （true）{//定義死循環
Thread.sleep（1000）;//線程每隔1秒激活一次
System.out.println（“Now Time： ” + new Date（）.toString（））;//輸出當前時間信息
}
}
catch（InterruptedException e）{
}
}
}
運行效果圖
3、完成一個java application應用程序，此應用程序公共類有一個double型類屬性（變量）x，初始值為0；在應用程序主進程中新開兩個線程，這兩個線程都進行死循環；第1個線程每隔300ms激活一次，令類屬性x自加1.0并輸出顯示；第2個線程每隔400ms激活一次，令類屬性x自加0.1并輸出顯示。
java程序（test3.java）
public class test3{
static double x=0; //定義一個double型變量并賦值
public static void main（String［］ args）{
new Thread（new OneThread（））.start（）;//開啟線程
new Thread（new TwoThread（））.start（）;//開啟線程
}
public static class OneThread implements Runnable{//通過實現Runnable接口來創建線程類
public void run（）{
while （true）{//定義死循環
try{//異常處理
Thread.sleep（300）;//線程每隔300ms激活一次
x=x+1;
System.out.println（“one：”+x）;//輸出x
}
catch（InterruptedException e）{
}
}
}
}
public static class TwoThread implements Runnable{//通過實現Runnable接口來創建線程類
public void run（）{
while （true）{//定義死循環
try{//異常處理
Thread.sleep（400）;//線程每隔400ms激活一次
x=x+0.1;
System.out.println（“two：”+x）;//輸出x
}
catch（InterruptedException e）{
}
}
}
}
}
運行效果圖
java 定時任務多線程處理
@Configuration
@EnableScheduling
public class ScheduleConfig implements SchedulingConfigurer， AsyncConfigurer{
/** 異步處理 */
public void configureTasks（ScheduledTaskRegistrar taskRegistrar）{
TaskScheduler taskScheduler = taskScheduler（）;
taskRegistrar.setTaskScheduler（taskScheduler）;
}
/** 定時任務多線程處理 */
@Bean（destroyMethod = “shutdown”）
public ThreadPoolTaskScheduler taskScheduler（）{
ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler（）;
scheduler.setPoolSize（20）;
scheduler.setThreadNamePrefix（“task-”）;
scheduler.setAwaitTerminationSeconds（60）;
scheduler.setWaitForTasksToCompleteOnShutdown（true）;
return scheduler;
}
/** 異步處理 */
public Executor getAsyncExecutor（）{
Executor executor = taskScheduler（）;
return executor;
}
/** 異步處理 異常 */
public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler（）{
return new SimpleAsyncUncaughtExceptionHandler（）;
}
}
工商網監
評論