erik/kobalt
erik/kobalt
1
0
Fork 0
mirror of https://github.com/ethauvin/kobalt.git synced 2025-04-26 00:17:11 -07:00
Code Releases Activity

Syntax.

Browse source
This commit is contained in:
Cedric Beust 2015-10-13 19:25:35 -07:00
parent ab131f3eb0
commit a6aa9afed9
1 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
src/main/kotlin/com/beust/kobalt/misc/KobaltExecutors.kt
View file

@ -66,12 +66,12 @@ public class KobaltExecutors {
val r = cs.take().get(remainingMs, TimeUnit.MILLISECONDS) val r = cs.take().get(remainingMs, TimeUnit.MILLISECONDS)
result.add(r) result.add(r)
remainingMs -= (System.currentTimeMillis() - start) remainingMs -= (System.currentTimeMillis() - start)
log(2, "Received ${r}, remaining: ${remainingMs} ms") log(2, "Received $r, remaining: $remainingMs ms")
i++ i++
} }
if (remainingMs < 0) { if (remainingMs < 0) {
warn("Didn't receive all the results in time: ${i} / ${tasks.size()}") warn("Didn't receive all the results in time: $i / ${tasks.size()}")
} else { } else {
log(2, "Received all results in ${maxMs - remainingMs} ms") log(2, "Received all results in ${maxMs - remainingMs} ms")
} }