mirror of
https://github.com/wassname/ray.git
synced 2026-07-09 07:59:29 +08:00
Fix Java MultithreadingTest (#5170)
This commit is contained in:
@@ -84,7 +84,7 @@ public class MultiThreadingTest extends BaseTest {
|
||||
// Test wait for one object in multi threads.
|
||||
RayObject<Integer> obj = Ray.call(MultiThreadingTest::echo, 100);
|
||||
runTestCaseInMultipleThreads(() -> {
|
||||
WaitResult<Integer> result = Ray.wait(ImmutableList.of(obj), 1, 1000);
|
||||
WaitResult<Integer> result = Ray.wait(ImmutableList.of(obj), 1, 2000);
|
||||
Assert.assertEquals(1, result.getReady().size());
|
||||
}, 1);
|
||||
|
||||
|
||||
Reference in New Issue
Block a user