# 更新

data-show/show-auto-turnover/src/main/java/com/bailuntec/job/QueueConsumerJob.java

@@ -50,7 +50,7 @@ public class QueueConsumerJob implements SimpleJob {
 
             List<DcBaseQueue> dcBaseQueueList = dcBaseQueueMapper.poll(shardingContext.getShardingItem());
 
-            dcBaseQueueList.forEach(dcBaseQueue -> {
+            dcBaseQueueList.parallelStream().forEach(dcBaseQueue -> {
                 BaseQueueMessage baseQueueMessage = JSON.parseObject(dcBaseQueue.getMessage(), BaseQueueMessage.class);
 
                 DcBaseStock dcBaseStock = dcBaseStockMapper.selectOneByExample(DcBaseStockExample.newAndCreateCriteria()