From 2c5caac806b02c91dfe94c2e56a7b46057d16740 Mon Sep 17 00:00:00 2001
From: snickersun <scy@incartech.cn>
Date: Thu, 19 Nov 2020 15:13:24 +0800
Subject: [PATCH] =?utf8?q?=E4=BF=AE=E6=94=B9Deliver=20Sending=20loop=20?=
 =?utf8?q?=E5=8F=91=E9=80=81=E9=80=BB=E8=BE=91=EF=BC=8C=E4=BF=9D=E8=AF=81?=
 =?utf8?q?=E4=B8=8D=E4=BC=9A=E5=9B=A0=E4=B8=BA=E9=87=8D=E5=A4=8D=E8=B0=83?=
 =?utf8?q?=E7=94=A8TriggerSendThread=E9=80=A0=E6=88=90=E5=8F=91=E9=80=81?=
 =?utf8?q?=E9=80=BB=E8=BE=91=E6=B7=B7=E4=B9=B1=E3=80=82?=
MIME-Version: 1.0
Content-Type: text/plain; charset=utf8
Content-Transfer-Encoding: 8bit

---
 .../enqualcomm/support/service/Deliver.java   | 23 +++++++++++++------
 1 file changed, 16 insertions(+), 7 deletions(-)

diff --git a/app/src/main/java/com/enqualcomm/support/service/Deliver.java b/app/src/main/java/com/enqualcomm/support/service/Deliver.java
index cc7adc24..6b6950ef 100644
--- a/app/src/main/java/com/enqualcomm/support/service/Deliver.java
+++ b/app/src/main/java/com/enqualcomm/support/service/Deliver.java
@@ -61,6 +61,7 @@ public class Deliver extends AbstractConnectionService {
   
   private static int isAppSetWifi = 0;
 
+  private static boolean sendloopruning=false;
 
 
   private static ReentrantLock mLock = new ReentrantLock();
@@ -104,10 +105,13 @@ public class Deliver extends AbstractConnectionService {
     delaySendMSG = new Runnable() {
       @Override
       public void run() {
-        mSendMSGHandler.removeCallbacks(delaySendMSG);
-        if (getAndSendMsgFromQueue()==true){
-          mSendMSGHandler.postDelayed(delaySendMSG,5000L);
-        }
+        sendloopruning=true;
+        while(getAndSendMsgFromQueue()==true)
+        {
+          //数据发送成功，则5秒后进行下一轮发送
+          Util.mSleep(5000);
+        } //没有数据可以发送，则退出sendloop
+        sendloopruning=false;
       }
     };
   }
@@ -143,9 +147,14 @@ public class Deliver extends AbstractConnectionService {
   }
   public static void triggerSendThread() {
 
-    mSendMSGHandler.removeCallbacks(delaySendMSG);
-    mSendMSGHandler.post(delaySendMSG);
-    ICLogger.i("triggerSendThread ");
+
+    if(sendloopruning==false) {
+      ICLogger.i("triggerSendThread !");
+      mSendMSGHandler.post(delaySendMSG);
+    }else{
+      ICLogger.i("triggerSendThread running skip !");
+    }
+
 //    delaySendMSG.run();
 //    mSendMSGHandler.sendEmptyMessage(1);
   }
-- 
2.17.1