java多線程開發(fā)ScheduledExecutorService簡化方式

更新時間：2022年03月08日 09:22:19 作者：kl

這篇文章主要為大家介紹了java多線程開發(fā)ScheduledExecutorService的簡化方式，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步

前言

java開發(fā)，多多少少會接觸到多線程的應(yīng)用開發(fā)場景，博主之前做多線程的時候就兩種方式，一個是繼承Thread一個是實(shí)現(xiàn)Runnable接口，不過用的多的還是實(shí)現(xiàn)Runnable接口，因?yàn)閷?shí)現(xiàn)Runnable接口可以做多線程資源共享！而java.util.concurrent.ScheduledExecutorService接口將大大簡化多線程應(yīng)用的開發(fā)！也能輕松解決任務(wù)定時執(zhí)行的問題！

java多線程的應(yīng)用場景

應(yīng)用場景一：

做過微信開發(fā)的都知道，微信的token是有失效時間的，而且每天獲取token都是有限制的，不能每次需要的時候取一次，只能快過期的時候重新去取，這個時候我們就可以給取token的這個操作單獨(dú)開個線程，每次取完后線程休眠一段繼續(xù)去取，這樣就保證了token永遠(yuǎn)都是有效的！

應(yīng)用場景二：

同樣是微信開發(fā)中的問題，微信服務(wù)器連我們服務(wù)器的時候，必須五秒內(nèi)響應(yīng)結(jié)果，不然微信就直接提示用戶，該服務(wù)不可用了。而我們不可能所有的業(yè)務(wù)都能做到五秒內(nèi)完成并響應(yīng)微信服務(wù)器。比如從微信服務(wù)器上下載用戶提交的文件保存到我們自己的文件服務(wù)器上，(微信服務(wù)器臨時保存用戶文件)，文件的上傳下載都是比較耗時的操作，我們肯定不能等文件上傳完了在響應(yīng)微信，所有得單獨(dú)開個線程還執(zhí)行文件的下載上傳操作

ScheduledExecutorService方法簡介

/**
     *指定delay時間后執(zhí)行任務(wù)
     * @param command 執(zhí)行的線程任務(wù) Runnable不能返回執(zhí)行結(jié)果
     * @param delay 指定某個時間后執(zhí)行
     * @param unit 指定時間單位
     * @return
     */
    public ScheduledFuture schedule(Runnable command, long delay, TimeUnit unit) {
        return null;
    }
    /**
     *指定delay時間后執(zhí)行任務(wù)
     * @param callable 執(zhí)行的線程任務(wù) Callable返回執(zhí)行結(jié)果
     * @param delay 指定某個時間后執(zhí)行
     * @param unit 指定時間單位
     * @param
     * @return
     */
    publicScheduledFutureschedule(Callablecallable, long delay, TimeUnit unit) {
        return null;
    }
    /**
     *等待initiaDelay時間后，每個period時間執(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) {
        //初始化兩個線城池大小的任務(wù)調(diào)度服務(wù)
        ScheduledExecutorService executorService= Executors.newScheduledThreadPool(2);
        //任務(wù)一：0秒后開始執(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秒后開始執(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í)行完，請知曉！";
            }
        },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è)置在任務(wù)二的執(zhí)行前面，任務(wù)三也要等到任務(wù)二執(zhí)行完后才能執(zhí)行，這個可以修改執(zhí)行時間自己測試測試，體會體會