|
|
|
@ -92,8 +92,10 @@ public class TbSqlBlockingQueue<E> implements TbSqlQueue<E> { |
|
|
|
}); |
|
|
|
|
|
|
|
logExecutor.scheduleAtFixedRate(() -> { |
|
|
|
log.info("[{}] queueSize [{}] totalAdded [{}] totalSaved [{}] totalFailed [{}]", |
|
|
|
params.getLogName(), queue.size(), addedCount.getAndSet(0), savedCount.getAndSet(0), failedCount.getAndSet(0)); |
|
|
|
if (queue.size() > 0 || addedCount.get() > 0 || savedCount.get() > 0 || failedCount.get() > 0) { |
|
|
|
log.info("[{}] queueSize [{}] totalAdded [{}] totalSaved [{}] totalFailed [{}]", |
|
|
|
params.getLogName(), queue.size(), addedCount.getAndSet(0), savedCount.getAndSet(0), failedCount.getAndSet(0)); |
|
|
|
} |
|
|
|
}, params.getStatsPrintIntervalMs(), params.getStatsPrintIntervalMs(), TimeUnit.MILLISECONDS); |
|
|
|
} |
|
|
|
|
|
|
|
|