Transpiled version (5752L) is out of date.
svoid test_ThreadPool() { new ThreadPool pool; print(pool); flagTest(flag -> pool.acquireThread((Runnable) flag), 10.0); print(pool); int n = pool.maxSize()*2; new IntVar counter; new IntVar waitCounter; pool.onCustomerMustWaitAlert(-> inc(waitCounter)); for immutable i to n: { var t = pool.acquireThread(r { sleepSeconds((i+1)*0.2); printWithMS(this + " done"); inc(counter); }); printWithMS("Acquired thread " + t); } counter.waitForValue(n); assertEquals(4, waitCounter!); print(pool); }
download show line numbers debug dex old transpilations
Travelled to 4 computer(s): bhatertpkbcr, ekrmjmnbrukm, mowyntqkapby, mqqgnosmbjvj
No comments. add comment
| Snippet ID: | #1033408 | 
| Snippet name: | test_ThreadPool (OK) | 
| Eternal ID of this version: | #1033408/9 | 
| Text MD5: | 41632b3a210b7a1a7e2b57536e8025f8 | 
| Author: | stefan | 
| Category: | javax / code execution | 
| Type: | JavaX fragment (include) | 
| Public (visible to everyone): | Yes | 
| Archived (hidden from active list): | No | 
| Created/modified: | 2021-11-02 02:04:36 | 
| Source code size: | 571 bytes / 22 lines | 
| Pitched / IR pitched: | No / No | 
| Views / Downloads: | 390 / 518 | 
| Version history: | 8 change(s) | 
| Referenced in: | [show references] |