java異步執(zhí)行可以使用線程，或者第三方消息中間件，如mq；

線程池的使用：

package com.example.demo.ExecutorTest;import java.util.concurrent.*;public class CachePool {public static class MyTask1 implements Runnable{private int i;MyTask1(int i){this.i=i;}@Overridepublic void run() {System.out.println(System.currentTimeMillis()+"Thread ID:"+Thread.currentThread().getId());System.out.println(i);try {Thread.sleep(100);} catch (InterruptedException e) {e.printStackTrace();}}}public static void main(String args[]){ThreadPoolExecutor es = new ThreadPoolExecutor(50, 50, 0L, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(), new ThreadFactory() {@Overridepublic Thread newThread(Runnable r) {Thread t = new Thread(r);t.setDaemon(true);System.out.println("創(chuàng)建線程"+t);return t;}});for (int i = 0;i<=10;i++){es.submit(new MyTask1(i));}es.shutdown();} }

?

線程池創(chuàng)建函數(shù)以及參數(shù):

public ThreadPoolExecutor(int corePoolSize,int maximumPoolSize,long keepAliveTime,TimeUnit unit,BlockingQueue<Runnable> workQueue,ThreadFactory threadFactory,RejectedExecutionHandler handler)

參數(shù)含義：

corePoolSize：核心池的大小，在創(chuàng)建了線程池后，線程池中的線程數(shù)為0，當(dāng)有任務(wù)來之后，就會創(chuàng)建一個線程去執(zhí)行任務(wù)，當(dāng)線程池中的線程數(shù)目達(dá)到corePoolSize后，就會把到達(dá)的任務(wù)放到緩存隊列當(dāng)中;

maximumPoolSize：線程池最大線程數(shù)，它表示在線程池中最多能創(chuàng)建多少個線程；這個參數(shù)是跟后面的阻塞隊列聯(lián)系緊密的；只有當(dāng)阻塞隊列滿了，如果還有任務(wù)添加到線程池的話，會嘗試new 一個Thread的進(jìn)行救急處理，立馬執(zhí)行對應(yīng)的runnable任務(wù)；如果繼續(xù)添加任務(wù)到線程池，且線程池中的線程數(shù)已經(jīng)達(dá)到了maximumPoolSize，那么線程就會就會執(zhí)行reject操作（這里后面會提及到）

keepAliveTime：表示線程沒有任務(wù)執(zhí)行時最多保持多久時間會終止；默認(rèn)情況下，只有當(dāng)線程池中的線程數(shù)大于corePoolSize時，keepAliveTime才會起作用；即當(dāng)線程池中的線程數(shù)大于corePoolSize時，如果一個線程空閑的時間達(dá)到keepAliveTime，則會終止，直到線程池中的線程數(shù)不超過corePoolSize。但是如果調(diào)用了allowCoreThreadTimeOut(boolean)方法并設(shè)置了參數(shù)為true，在線程池中的線程數(shù)不大于corePoolSize時，keepAliveTime參數(shù)也會起作用，直到線程池中的阻塞隊列大小為0；（這部分通過查看ThreadPoolExecutor的源碼分析--getTask()部分）；

unit：參數(shù)keepAliveTime的時間單位，有7種取值，在TimeUnit類中有7種靜態(tài)屬性（時間單位）

workQueue：一個阻塞隊列，用來存儲等待執(zhí)行的任務(wù)，這個參數(shù)的選擇也很重要，會對線程池的運行過程產(chǎn)生重大影響，一般來說，這里的阻塞隊列有以下幾種選擇　　

　　ArrayBlockingQueue;

　　LinkedBlockingQueue;

　　SynchronousQueue;

　　ArrayBlockingQueue和PriorityBlockingQueue使用較少，一般使用LinkedBlockingQueue和Synchronous。線程池的排隊策略與BlockingQueue有關(guān)。

threadFactory：線程工廠，主要用來創(chuàng)建線程：默認(rèn)值?DefaultThreadFactory；

handler：表示當(dāng)拒絕處理任務(wù)時的策略，就是上面提及的reject操作；有以下四種取值：

　　ThreadPoolExecutor.AbortPolicy:丟棄任務(wù)并拋出RejectedExecutionException異常。（默認(rèn)handle）

　　ThreadPoolExecutor.DiscardPolicy：也是丟棄任務(wù)，但是不拋出異常。

　　ThreadPoolExecutor.DiscardOldestPolicy：丟棄隊列最前面的任務(wù)，然后重新嘗試執(zhí)行任務(wù)（重復(fù)此過程）

　　ThreadPoolExecutor.CallerRunsPolicy：由調(diào)用線程處理該任務(wù)

?

?

?

總結(jié)

以上是生活随笔為你收集整理的java异步执行任务的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。