diff --git a/device-manager/src/main/java/com/mortals/xhx/thread/DeviceUpdateComsumerThread.java b/device-manager/src/main/java/com/mortals/xhx/thread/DeviceUpdateComsumerThread.java
index 286fd30023756579b80f0d4d03c258215f1b8428..a0885d1578414a047c25bbd913b6076feedd22c1 100644
--- a/device-manager/src/main/java/com/mortals/xhx/thread/DeviceUpdateComsumerThread.java
+++ b/device-manager/src/main/java/com/mortals/xhx/thread/DeviceUpdateComsumerThread.java
@@ -33,23 +33,21 @@ public class DeviceUpdateComsumerThread extends AbstractThread {
 
     @Override
     protected int getSleepTime() {
-        return 1000;
+        return 500;
     }
 
     @Override
-    protected void process()  {
+    protected void process() {
         log.info("DeviceUpdateComsumerThread process");
         List<DeviceEntity> waitUpdateDeviceList = new ArrayList<>();
-        while (true) {
-            DeviceEntity deviceEntity = cacheService.lpop(RedisKey.KEY_DEVICE_UPDATE_QUEUE, DeviceEntity.class);
-            if (ObjectUtils.isEmpty(deviceEntity)) {
-                log.info("deviceEntity:{}", deviceEntity == null);
-                break;
-            } else {
-                waitUpdateDeviceList.add(deviceEntity);
-            }
+
+        DeviceEntity deviceEntity = cacheService.lpop(RedisKey.KEY_DEVICE_UPDATE_QUEUE, DeviceEntity.class);
+        if (!ObjectUtils.isEmpty(deviceEntity)) {
+           // log.info("deviceEntity:{}", deviceEntity == null);
+            waitUpdateDeviceList.add(deviceEntity);
         }
 
+
         if (!ObjectUtils.isEmpty(waitUpdateDeviceList)) {
             log.info("updateDeviceList size:{}", waitUpdateDeviceList.size());
             deviceService.update(waitUpdateDeviceList);