逍遥阁

java异步执行器

关键词: java

java异步执行器

```
package com.api.runner;

import lombok.extern.log4j.Log4j2;
import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;
import org.springframework.stereotype.Component;

import java.util.concurrent.*;

@Log4j2
@Component
public class DemoRunner implements ApplicationRunner {

private Executor getExecutor() {
        int corePoolSize = Runtime.getRuntime().availableProcessors();
        int maximumPoolSize = corePoolSize * 2;
        long keepAliveTime = 3000;
        BlockingQueue<Runnable> workQueue = new LinkedBlockingQueue<>();
        ThreadFactory threadFactory = Executors.defaultThreadFactory();
        RejectedExecutionHandler handler = new ThreadPoolExecutor.DiscardOldestPolicy();
        return new ThreadPoolExecutor(corePoolSize, maximumPoolSize, keepAliveTime, TimeUnit.MILLISECONDS, workQueue, threadFactory, handler);
    }

@Override
    public void run(ApplicationArguments args) {
        run01();
        run02();
    }

private void run01() {
        Executor executor = Executors.newCachedThreadPool();
        executor.execute(() -> {
            log.info("run01");
        });
    }

/**
     * 推荐写法
     */
    private void run02() {
        Executor executor = getExecutor();
        executor.execute(() -> {
            log.info("run02");
        });
    }

}
```

admin
2022-07-07 19:15:20
phantoscope

文章分类

文章标签

文章归档

友情链接

java异步执行器