@ -28,7 +28,7 @@ public class CustomerDataJob {
// 指定 ring buffer字节大小,必需为2的N次方(能将求模运算转为位运算提高效率 ),否则影响性能
private static final int BUFFER_SIZE = 1024 * 1024;
//固定线程数
private static final int THREAD_NUMBERS = 100;
private static final int THREAD_NUMBERS = 80;
//创建线程池
ExecutorService executors = Executors.newFixedThreadPool(THREAD_NUMBERS);