@@ -56,11 +56,11 @@ public void multiThread() throws Exception {
56
56
57
57
final Collection <String > result = new ConcurrentLinkedQueue <>();
58
58
final Thread fast = new Thread (() -> {
59
- arangoDB .db ().query ("return sleep(.01 )" , null , null , null );
59
+ arangoDB .db ().query ("return sleep(0.1 )" , null , null , null );
60
60
result .add (FAST );
61
61
});
62
62
final Thread slow = new Thread (() -> {
63
- arangoDB .db ().query ("return sleep(.05 )" , null , null , null );
63
+ arangoDB .db ().query ("return sleep(0.5 )" , null , null , null );
64
64
result .add (SLOW );
65
65
});
66
66
slow .start ();
@@ -84,11 +84,11 @@ public void multiThreadSameDatabases() throws Exception {
84
84
85
85
final Collection <String > result = new ConcurrentLinkedQueue <>();
86
86
final Thread t1 = new Thread (() -> {
87
- db .query ("return sleep(.01 )" , null , null , null );
87
+ db .query ("return sleep(0.1 )" , null , null , null );
88
88
result .add ("1" );
89
89
});
90
90
final Thread t2 = new Thread (() -> {
91
- db .query ("return sleep(.01 )" , null , null , null );
91
+ db .query ("return sleep(0.1 )" , null , null , null );
92
92
result .add ("1" );
93
93
});
94
94
t2 .start ();
0 commit comments