0
ThreadPoolExecutor executor = new ThreadPoolExecutor(10, 50, 60, TimeUnit.SECONDS,
new SynchronousQueue<>(),
Executors.defaultThreadFactory(),
new ThreadPoolExecutor.CallerRunsPolicy()
);
@KafkaListener(topics = "writeData")
public void writeData(String message){
executor.execute(() -> {
xxxxxx
xxxxxxx
});
}
使用trace如何查看lamda里面的调用时间? trace writeData 不能打印内部具体的时间