why???

cip4 · Jan 16, 2025 · 1d36f5c · 1d36f5c
1 parent 5b8e9ea
commit 1d36f5c
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/src/test/java/org/cip4/bambi/core/AbstractDeviceTest.java b/src/test/java/org/cip4/bambi/core/AbstractDeviceTest.java
@@ -272,13 +272,14 @@ public void testDoSynchMulti() throws Exception
 			assertTrue(device.doSynchronous(qee));
 			ThreadUtil.sleep(1);
 		}
-		for (int i = 0; i < 4234; i++)
+		for (int i = 0; i < 6234; i++)
 		{
 			if (queueProcessor.getQueue().numEntries(EnumQueueEntryStatus.Waiting) > 0)
 			{
 				ThreadUtil.sleep(123);
 			}
 		}
+		ThreadUtil.sleep(123);
 		assertNotEquals(0, queueProcessor.getQueue().numEntries(EnumQueueEntryStatus.Completed));
 		assertEquals(0, queueProcessor.getQueue().numEntries(EnumQueueEntryStatus.Waiting));
 	}
@@ -304,13 +305,14 @@ public void testDoSynchMulti4() throws Exception
 			assertTrue(device.doSynchronous(qee));
 			ThreadUtil.sleep(1);
 		}
-		for (int i = 0; i < 4234; i++)
+		for (int i = 0; i < 6234; i++)
 		{
 			if (queueProcessor.getQueue().numEntries(EnumQueueEntryStatus.Waiting) > 0)
 			{
 				ThreadUtil.sleep(123);
 			}
 		}
+		ThreadUtil.sleep(123);
 		assertNotEquals(0, queueProcessor.getQueue().numEntries(EnumQueueEntryStatus.Completed));
 		assertEquals(0, queueProcessor.getQueue().numEntries(EnumQueueEntryStatus.Waiting));
 	}
@@ -336,13 +338,14 @@ public void testDoAsynchMulti() throws Exception
 			assertTrue(device.doSynchronous(qee));
 			ThreadUtil.sleep(1);
 		}
-		for (int i = 0; i < 4234; i++)
+		for (int i = 0; i < 6234; i++)
 		{
 			if (queueProcessor.getQueue().numEntries(EnumQueueEntryStatus.Waiting) > 0)
 			{
 				ThreadUtil.sleep(123);
 			}
 		}
+		ThreadUtil.sleep(123);
 		assertNotEquals(0, queueProcessor.getQueue().numEntries(EnumQueueEntryStatus.Completed));
 		assertEquals(0, queueProcessor.getQueue().numEntries(EnumQueueEntryStatus.Waiting));
 	}