使用线程池异步执行

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import lombok.extern.slf4j.Slf4j;
@Slf4j
public class AsyncBaseQueue {
  private static final int THREAD_SIZE = Runtime.getRuntime().availableProcessors();
  
  private static final int QUEUE_SIZE = 10000;
  
  private static ExecutorService senderAsync =
      new ThreadPoolExecutor(THREAD_SIZE,
          THREAD_SIZE,
          60L,
          TimeUnit.SECONDS,
          new ArrayBlockingQueue<Runnable>(QUEUE_SIZE),
          new ThreadFactory() {
            @Override
            public Thread newThread(Runnable r) {
              Thread t = new Thread(r);
              t.setName("rabbitmq_client_async_sender");
              return t;
            }
          },
          new java.util.concurrent.RejectedExecutionHandler() {
            @Override
            public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
              log.error("async sender is error rejected, runnable: {}, executor: {}", r, executor);
            }
          });
      
    public static void submit(Runnable runnable) {
      senderAsync.submit(runnable);
    } 
      
}

private void sendKernel(Message message) {
    // 使用异步线程池进行发送消息
    AsyncBaseQueue.submit(() -> {
      // 具体业务     
    });
  }