<dependency>
            <groupId>co.paralleluniverse</groupId>
            <artifactId>quasar-core</artifactId>
            <version>0.7.9</version>
            <classifier>jdk8</classifier>
        </dependency>

package com.example.ai;
?
import co.paralleluniverse.fibers.Fiber;
import co.paralleluniverse.fibers.SuspendExecution;
import co.paralleluniverse.strands.SuspendableRunnable;
?
import java.util.concurrent.ArrayBlockingQueue;
?
?
public class WorkTools {
? ? //協(xié)程池中默認(rèn)協(xié)程的個(gè)數(shù)為5
? ? private static int WORK_NUM = 5;
? ? //隊(duì)列默認(rèn)任務(wù)為100
? ? private static int TASK_COUNT = 100;
?
? ? //工做協(xié)程數(shù)組
? ? private Fiber[] workThreads;
? ? //等待隊(duì)列
? ? private final ArrayBlockingQueue<SuspendableRunnable> taskQueue;
?
? ? //用戶在構(gòu)造這個(gè)協(xié)程池時(shí)，但愿啟動(dòng)的協(xié)程數(shù)
? ? private final int workerNum;
?
?
? ? //構(gòu)造方法：建立具備默認(rèn)協(xié)程個(gè)數(shù)的協(xié)程池
? ? public WorkTools() {
? ? ? ? this(WORK_NUM,TASK_COUNT);
? ? }
?
? ? //建立協(xié)程池,workNum為協(xié)程池中工做協(xié)程的個(gè)數(shù)
? ? public WorkTools(int workerNum, int taskCount) {
? ? ? ? if (workerNum <= 0) {
? ? ? ? ? ? workerNum = WORK_NUM;
? ? ? ? }
? ? ? ? if (taskCount <= 0) {
? ? ? ? ? ? taskCount = TASK_COUNT;
? ? ? ? }
? ? ? ? this.workerNum = workerNum;
? ? ? ? taskQueue = new ArrayBlockingQueue(taskCount);
? ? ? ? workThreads = new Fiber[workerNum];
? ? ? ? for (int i = 0; i < workerNum; i++) {
? ? ? ? ? ? int finalI = i;
? ? ? ? ? ? workThreads[i] = new Fiber<>(new SuspendableRunnable() {
? ? ? ? ? ? ? ? @Override
? ? ? ? ? ? ? ? public void run() throws SuspendExecution, InterruptedException {
? ? ? ? ? ? ? ? ? ? SuspendableRunnable runnable = null;
? ? ? ? ? ? ? ? ? ? while (true){
? ? ? ? ? ? ? ? ? ? ? ? try{
? ? ? ? ? ? ? ? ? ? ? ? ? ? //取任務(wù)，沒有則阻塞。
? ? ? ? ? ? ? ? ? ? ? ? ? ? runnable = taskQueue.take();
? ? ? ? ? ? ? ? ? ? ? ? }catch (Exception e){
? ? ? ? ? ? ? ? ? ? ? ? ? ? System.out.println(e.getMessage());
? ? ? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? ? ? //存在任務(wù)則運(yùn)行。
? ? ? ? ? ? ? ? ? ? ? ? if(runnable != null){
? ? ? ? ? ? ? ? ? ? ? ? ? ? runnable.run();
? ? ? ? ? ? ? ? ? ? ? ? }
?
? ? ? ? ? ? ? ? ? ? ? ? runnable = null;
? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? }
? ? ? ? ? ? }); ?//new一個(gè)工做協(xié)程
?
? ? ? ? ? ? workThreads[i].start(); ?//啟動(dòng)工做協(xié)程
?
? ? ? ? }
?
? ? ? ? Runtime.getRuntime().availableProcessors();
? ? }
? ? //執(zhí)行任務(wù)，其實(shí)就是把任務(wù)加入任務(wù)隊(duì)列，何時(shí)執(zhí)行由協(xié)程池管理器決定
? ? public void execute(SuspendableRunnable task) {
? ? ? ? try {
? ? ? ? ? ? taskQueue.put(task); ? //put:阻塞接口的插入
? ? ? ? } catch (Exception e) {
? ? ? ? ? ? // TODO: handle exception
? ? ? ? ? ? System.out.println("阻塞");
? ? ? ? }
? ? }
? ? //銷毀協(xié)程池,該方法保證全部任務(wù)都完成的狀況下才銷毀全部協(xié)程，不然等待任務(wù)完成再銷毀
? ? public void destory() {
? ? ? ? //工做協(xié)程中止工做，且置為null
? ? ? ? System.out.println("ready close thread...");
? ? ? ? for (int i = 0; i < workerNum; i++) {
?
? ? ? ? ? ? workThreads[i] = null; //help gc
? ? ? ? }
? ? ? ? taskQueue.clear(); ?//清空等待隊(duì)列
? ? }
? ? //覆蓋toString方法，返回協(xié)程信息：工做協(xié)程個(gè)數(shù)和已完成任務(wù)個(gè)數(shù)
? ? @Override
? ? public String toString() {
? ? ? ? return "WorkThread number:" + workerNum + " ==分割線== wait task number:" + taskQueue.size();
? ? }
}

package com.example.ai;
 
import co.paralleluniverse.strands.SuspendableRunnable;
import lombok.SneakyThrows;
 
import org.springframework.boot.autoconfigure.SpringBootApplication;
 
import java.util.concurrent.CountDownLatch;
 
 
 
@SpringBootApplication
 
 
public class AiApplication {
 
    @SneakyThrows
    public static void main(String[] args) {
        //等待協(xié)程任務(wù)完畢后再結(jié)束主線程
        CountDownLatch cdl = new CountDownLatch(50);
        //開啟5個(gè)協(xié)程，50個(gè)任務(wù)列隊(duì)。
        WorkTools myThreadPool = new WorkTools(5, 50);
        for (int i = 0; i< 50; i++){
            int finalI = i;
            myThreadPool.execute(new SuspendableRunnable() {
                @Override
                public void run() {
                    System.out.println(finalI);
                    try {
                        //延遲1秒
                        Thread.sleep(1000);
                        cdl.countDown();
                    } catch (InterruptedException e) {
                        System.out.println("阻塞中");
                    }
                }
            });
 
        }
        //阻塞
        cdl.await();
    }
 
}