V
вместо проверки, что все таски закончились - ты стопаешь все потоки воркеры. Не кажется, что это не совсем то?
Size: a a a
2021 May 12
V
ГР
интересно как executorService.awaitTermination
срабатывает также походу интересно через какое время он проверяет выполнение всех задач
срабатывает также походу интересно через какое время он проверяет выполнение всех задач
V
ну посмотри код
ГР
public final long awaitNanos(long nanosTimeout)
throws InterruptedException {
if (Thread.interrupted())
throw new InterruptedException();
// We don't check for nanosTimeout <= 0L here, to allow
// awaitNanos(0) as a way to "yield the lock".
final long deadline = System.nanoTime() + nanosTimeout;
long initialNanos = nanosTimeout;
Node node = addConditionWaiter();
long savedState = fullyRelease(node);
int interruptMode = 0;
while (!isOnSyncQueue(node)) {
if (nanosTimeout <= 0L) {
transferAfterCancelledWait(node);
break;
}
if (nanosTimeout > SPIN_FOR_TIMEOUT_THRESHOLD)
LockSupport.parkNanos(this, nanosTimeout);
if ((interruptMode = checkInterruptWhileWaiting(node)) != 0)
break;
nanosTimeout = deadline - System.nanoTime();
}
if (acquireQueued(node, savedState) && interruptMode != THROW_IE)
interruptMode = REINTERRUPT;
if (node.nextWaiter != null)
unlinkCancelledWaiters();
if (interruptMode != 0)
reportInterruptAfterWait(interruptMode);
long remaining = deadline - System.nanoTime(); // avoid overflow
return (remaining <= initialNanos) ? remaining : Long.MIN_VALUE;
}хрен просышь
V
сюда не нужно смотреть,
Condition.awaitNanos нужно понять. С такими вопросами лучше в @javastart, там охотнее ответятГР
да там заебли со своим жаком фрэско
V
Ору
V
А в чем проблема? Один раз на канал зашел и не паришься больше
ch
Эффективнее не пускать в чат
ch
Отключите уведомления в чате
SZ
https://github.com/lampepfl/dotty/releases/tag/3.0.0 дотти все же релизят чтоли)
AK
огого. но зачем?
IE
Очередной убийца джавы?)
AE
если не обосрутся
AE
это скала 3