求一个线程池的实现方法

Question

求一个线程的实现方法

之前遇到一个线程的写法，可以把service的方法直接通过线程池异步执行。
只记得大概的写法了

//一个普通的service
public class Aservice {
  public class b() {
  .....
}
}

//这是一个线程池工具类，具体的代码忘记了，跪求大佬指点迷津
public class ExecutorUtil {

  private final static Executor EXECUTOR = new ThreadPoolExecutor(8, 16, 5000, TimeUnit.MILLISECONDS,
      new LinkedBlockingQueue<>(10), new ThreadPoolExecutor.CallerRunsPolicy());

public static void async(...) {
...
}
}
//使用方法大概是这样的，这样就可以直接把b方法异步执行
ExecutorUtil.EXECUTOR.async(()->b);

Answer 1

private ExecutorService worker = new ThreadPoolExecutor(1, 10,
            60, TimeUnit.SECONDS,
            new LinkedBlockingQueue<Runnable>(2*60));

     // 异步
        worker.execute(()->{
            try {
                Aservice.b();
            } catch (Exception e) {
                log.error("async failed :{}", e);
            } 
        });

既然你说是springboot 那么还有注解方式异步
@Async

@Async 的使用_犹斗困兽的博客-CSDN博客_@async 1 场景@Async用于异步处理2 使用@Async作用于方法上 @Async public void testAsync() { log.info("testAsync"); }@EnableAsync在主类@EnableAsync@SpringBootApplicationpublic class TestApplication{ public static void main( String[] arg https://blog.csdn.net/waitu88/article/details/119783542

还有手动创建线程池的代码

//线程池执行器
        ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(
                5,
                10,
                10,
                TimeUnit.MILLISECONDS,
                new ArrayBlockingQueue(3),
                new ThreadPoolExecutor.AbortPolicy());
threadPoolExecutor.execute(thread1);

最后再来一篇线程池的文章:

如何正确使用线程池_ᅟᅟᅟᅟᅟ的博客-CSDN博客_线程池的使用 如何正确使用线程池 https://blog.csdn.net/manhengwei/article/details/122409320?ops_request_misc=%257B%2522request%255Fid%2522%253A%2522166211227716782425198137%2522%252C%2522scm%2522%253A%252220140713.130102334.pc%255Fblog.%2522%257D&request_id=166211227716782425198137&biz_id=0&utm_medium=distribute.pc_search_result.none-task-blog-2~blog~first_rank_ecpm_v1~rank_v31_ecpm-1-122409320-null-null.nonecase&utm_term=%E7%BA%BF%E7%A8%8B%E6%B1%A0&spm=1018.2226.3001.4450