From 74658fcd17a88f70da1b47a3c0301ba2859276f0 Mon Sep 17 00:00:00 2001 From: b2baccline <23131013+b2baccline@users.noreply.github.com> Date: Mon, 25 May 2020 18:38:44 +0800 Subject: [PATCH] =?UTF-8?q?:art:=20=E4=BF=AE=E6=94=B9QueueThread=E4=B8=ADd?= =?UTF-8?q?efault=E5=B1=9E=E6=80=A7=E4=B8=BA=E7=A7=81=E6=9C=89=E9=9D=99?= =?UTF-8?q?=E6=80=81=E5=8F=98=E9=87=8F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../common/core/thread/AbstractQueueThread.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git 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 index c1b8907e..65f737fd 100644 --- 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,25 +19,25 @@ import java.util.concurrent.TimeUnit; @Slf4j public abstract class AbstractQueueThread extends Thread implements InitializingBean { private final BlockingQueue queue = new LinkedBlockingQueue(); - private final long defaultBatchSize = 100; - private final long defaultBatchTimeout = 30000; + private final static long DEFAULT_BATCH_SIZE = 100; + private final static long DEFAULT_BATCH_TIMEOUT = 30000; public void putObject(T t) { try { if (t != null) { queue.put(t); } - } catch (InterruptedException e) { - e.printStackTrace(); + } catch (Exception e) { + log.error("{} putObject error, param: {}", this.getClass().toString(), t, e); } } public long getBatchSize() { - return defaultBatchSize; + return DEFAULT_BATCH_SIZE; } public long getBatchTimeout() { - return defaultBatchTimeout; + return DEFAULT_BATCH_TIMEOUT; } @Override