java多線程開(kāi)發(fā)ScheduledExecutorService簡(jiǎn)化方式

前言
java開(kāi)發(fā),多多少少會(huì)接觸到多線程的應(yīng)用開(kāi)發(fā)場(chǎng)景,博主之前做多線程的時(shí)候就兩種方式,一個(gè)是繼承Thread一個(gè)是實(shí)現(xiàn)Runnable接口,不過(guò)用的多的還是實(shí)現(xiàn)Runnable接口,因?yàn)閷?shí)現(xiàn)Runnable接口可以做多線程資源共享!而java.util.concurrent.ScheduledExecutorService接口將大大簡(jiǎn)化多線程應(yīng)用的開(kāi)發(fā)!也能輕松解決任務(wù)定時(shí)執(zhí)行的問(wèn)題!
java多線程的應(yīng)用場(chǎng)景
應(yīng)用場(chǎng)景一:
做過(guò)微信開(kāi)發(fā)的都知道,微信的token是有失效時(shí)間的,而且每天獲取token都是有限制的,不能每次需要的時(shí)候取一次,只能快過(guò)期的時(shí)候重新去取,這個(gè)時(shí)候我們就可以給取token的這個(gè)操作單獨(dú)開(kāi)個(gè)線程,每次取完后線程休眠一段繼續(xù)去取,這樣就保證了token永遠(yuǎn)都是有效的 !
應(yīng)用場(chǎng)景二:
同樣是微信開(kāi)發(fā)中的問(wèn)題,微信服務(wù)器連我們服務(wù)器的時(shí)候,必須五秒內(nèi)響應(yīng)結(jié)果,不然微信就直接提示用戶,該服務(wù)不可用了。而我們不可能所有的業(yè)務(wù)都能做到五秒內(nèi)完成并響應(yīng)微信服務(wù)器。比如從微信服務(wù)器上下載用戶提交的文件保存到我們自己的文件服務(wù)器上,(微信服務(wù)器臨時(shí)保存用戶文件),文件的上傳下載都是比較耗時(shí)的操作,我們肯定不能等文件上傳完了在響應(yīng)微信,所有得單獨(dú)開(kāi)個(gè)線程還執(zhí)行文件的下載上傳操作
ScheduledExecutorService方法簡(jiǎn)介
/**
*指定delay時(shí)間后執(zhí)行任務(wù)
* @param command 執(zhí)行的線程任務(wù) Runnable不能返回執(zhí)行結(jié)果
* @param delay 指定某個(gè)時(shí)間后執(zhí)行
* @param unit 指定時(shí)間單位
* @return
*/
public ScheduledFuture schedule(Runnable command, long delay, TimeUnit unit) {
return null;
}
/**
*指定delay時(shí)間后執(zhí)行任務(wù)
* @param callable 執(zhí)行的線程任務(wù) Callable返回執(zhí)行結(jié)果
* @param delay 指定某個(gè)時(shí)間后執(zhí)行
* @param unit 指定時(shí)間單位
* @param
* @return
*/
publicScheduledFutureschedule(Callablecallable, long delay, TimeUnit unit) {
return null;
}
/**
*等待initiaDelay時(shí)間后,每個(gè)period時(shí)間執(zhí)行一次
* @param command
* @param initialDelay
* @param period
* @param unit
* @return
*/
public ScheduledFuture scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit) {
return null;
}
//scheduleWithFixedDelay和scheduleAtFixedRate差不多
public ScheduledFuture scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit) {
return null;
}
實(shí)例
/**
* @author kl by 2016/5/14
* @boke www.kailing.pub
*/
public class Test {
public static int count=0;
public static void main(String[] args) {
//初始化兩個(gè)線城池大小的任務(wù)調(diào)度服務(wù)
ScheduledExecutorService executorService= Executors.newScheduledThreadPool(2);
//任務(wù)一:0秒后開(kāi)始執(zhí)行,之后每秒執(zhí)行一次
final ScheduledFuture test1= executorService.scheduleAtFixedRate(new Runnable() {
public void run() {
System.out.println("任務(wù)一執(zhí)行第"+(count++)+"次 "+Thread.currentThread());
}
},0, 1,TimeUnit.SECONDS);
//任務(wù)二:6秒后開(kāi)始執(zhí)行,并返回執(zhí)行結(jié)果
final ScheduledFuture test2 = executorService.schedule(new Callable() {
public Object call() {
System.out.println("任務(wù)二執(zhí)行,傳遞執(zhí)行結(jié)果給任務(wù)三 "+Thread.currentThread());
return "任務(wù)二已執(zhí)行完,請(qǐng)知曉!";
}
},6,TimeUnit.SECONDS);
//任務(wù)三:8秒后執(zhí)行,打印任務(wù)二的結(jié)果,終止任務(wù)一
executorService.schedule(new Runnable() {
public void run() {
try {
System.out.println(test2.get());
}catch (Exception e){
e.printStackTrace();
}
System.out.println("任務(wù)三執(zhí)行,任務(wù)一終止 "+Thread.currentThread());
test1.cancel(true);
}
},8,TimeUnit.SECONDS);
System.out.println("我是最先執(zhí)行的嗎?不一定,雖然我是主線程 "+Thread.currentThread());
}
}ps:因?yàn)槿蝿?wù)三種涉及了任務(wù)二的執(zhí)行結(jié)果,所以即使任務(wù)三的執(zhí)行時(shí)間設(shè)置在任務(wù)二的執(zhí)行前面,任務(wù)三也要等到任務(wù)二執(zhí)行完后才能執(zhí)行 ,這個(gè)可以修改執(zhí)行時(shí)間自己測(cè)試測(cè)試,體會(huì)體會(huì)
實(shí)例結(jié)果

以上就是java多線程開(kāi)發(fā)ScheduledExecutorService簡(jiǎn)化方式的詳細(xì)內(nèi)容,更多關(guān)于java多線程開(kāi)發(fā)ScheduledExecutorService簡(jiǎn)化的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章!
相關(guān)文章
Java?Stream比較兩個(gè)List的差異并取出不同的對(duì)象四種方法
今天開(kāi)發(fā)一個(gè)需求時(shí)要對(duì)A和B兩個(gè)List集合遍歷,并比較出集合A有,而集合B沒(méi)有的值,下面這篇文章主要給大家介紹了關(guān)于Java?Stream比較兩個(gè)List的差異并取出不同對(duì)象的四種方法,需要的朋友可以參考下2024-01-01
SpringBoot緩存預(yù)熱實(shí)戰(zhàn)
緩存預(yù)熱是一種常見(jiàn)的優(yōu)化策略,旨在提高系統(tǒng)的響應(yīng)速度和性能,本文主要介紹了SpringBoot緩存預(yù)熱實(shí)戰(zhàn)指南,具有一定的參考價(jià)值,感興趣的可以了解一下2025-01-01
SpringBoot通過(guò)ThreadLocal實(shí)現(xiàn)登錄攔截詳解流程
這篇文章主要介紹了SpringBoot(HandlerInterceptor)+ThreadLocal實(shí)現(xiàn)登錄攔截,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2022-05-05
Java實(shí)現(xiàn)的微信公眾號(hào)獲取微信用戶信息示例
這篇文章主要介紹了Java實(shí)現(xiàn)的微信公眾號(hào)獲取微信用戶信息,結(jié)合實(shí)例形式分析了Java微信公眾號(hào)獲取微信用戶信息相關(guān)原理、步驟與操作注意事項(xiàng),需要的朋友可以參考下2019-10-10

