🎨 提高默认的批处理数据大小

2020-08-05 11:44:04 +08:00
parent 1e3b0b966c
commit 24526abceb
1 changed files with 1 additions and 1 deletions
--- a/ballcat-common/ballcat-common-core/src/main/java/com/hccake/ballcat/common/core/thread/AbstractQueueThread.java
+++ b/ballcat-common/ballcat-common-core/src/main/java/com/hccake/ballcat/common/core/thread/AbstractQueueThread.java
@@ -19,7 +19,7 @@ public abstract class AbstractQueueThread<T> extends Thread implements Initializ

 	private final BlockingQueue<T> queue = new LinkedBlockingQueue<>();

-	private final static long DEFAULT_BATCH_SIZE = 100;
+	private final static long DEFAULT_BATCH_SIZE = 500;

 	/**
 	 * 默认时长 30秒；单位 毫秒