2020年JAVA自定義任務(wù)類定時執(zhí)行任務(wù)范本.doc

1、java 自定義任務(wù)類定時執(zhí)行任務(wù)范本Callable和 Future 接口Callable是類似于 Runnable 的接口，實現(xiàn) Callable接口的類和實現(xiàn) Runnable 的類都是可被其它線程執(zhí)行的任務(wù)。Callable和 Runnable 有幾點不同：（ 1）Callable 規(guī)定的方法是 call() ，而 Runnable 規(guī)定的方法是 run().（ 2）Callable 的任務(wù)執(zhí)行后可返回值，而 Runnable 的任務(wù)是不能返回值的。（ 3）call() 方法可拋出異常，而 run() 方法是不能拋出異常的。（ 4）運行 Callable 任務(wù)可拿到一個 Future

2、對象， Future 表示異步計算的結(jié)果。它提供了檢查計算是否完成的方法，以等待計算的完成，并檢索計算的結(jié)果。通過 Future 對象可了解任務(wù)執(zhí)行情況， 可取消任務(wù)的執(zhí)行， 還可獲取任務(wù)執(zhí)行的結(jié)果。復(fù)制代碼代碼如下 : package.yao; importjava.util.concurrent.Callable; importjava.util.concurrent.ExecutorService; importjava.util.concurrent.Executors; importjava.util.concurrent.Future;publicclassCallableAndF

3、uture/* 自定義一個任務(wù)類，實現(xiàn) Callable 接口*/publicstaticclassMyCallableClassimplementsCallable/ 標志位privateintflag=0;publicMyCallableClass(intflag)this.flag=flag;publicStringcall()throwsExceptionif(this.flag=0)/ 如果 flag 的值為 0，則立即返回returnflag=0;if(this.flag=1)/ 如果 flag 的值為 1，做一個無限循環(huán)trywhile(true)System.out.print

4、ln(looping.);Thread.sleep(2000);catch(InterruptedExceptione)System.out.println(Interrupted);returnfalse;else/falg不為 0 或者 1，則拋出異常thrownewException(Badflagvalue!);publicstaticvoidmain(Stringargs)/定義 3 個 Callable類型的任務(wù)MyCallableClasstask1=newMyCallableClass(0);MyCallableClasstask2=newMyCallableClass(1);

5、MyCallableClasstask3=newMyCallableClass(2);/ 創(chuàng)建一個執(zhí)行任務(wù)的服務(wù)ExecutorServicees=Executors.newFixedThreadPool(3);try/ 提交并執(zhí)行任務(wù)，任務(wù)啟動時返回了一個 Future 對象，/ 如果想得到任務(wù)執(zhí)行的結(jié)果或者是異常可對這個 Future 對象進行操作Futurefuture1=es.submit(task1);/ 獲得第一個任務(wù)的結(jié)果，如果調(diào)用 get 方法，當前線程會等待任務(wù)執(zhí)行完畢后才往下執(zhí)行System.out.println(task1:+future1.get();Futurefuture2=es.submit(task2);/ 等待 5 秒后，再停止第二個任務(wù)。因為第二個任務(wù)進行的是無限循環(huán)Thread.sleep(5000);System.out.println(task2cancel:+future2.cancel(true);/ 獲取第三個任務(wù)的輸出，因為執(zhí)行第三個任務(wù)會引起異常/ 所以下面的語句將引起異常的拋出Futurefuture3=es.submit(task3);System.out.println(task3: