6566676869707172737475
} sync.await(i); } consumer.poll0(); } finally { sync.unregister(); } } void attemptReceive(long timeout, TimeUnit unit) throws SuspendExecution, InterruptedException, TimeoutException { if (isClosed())
8990919293949596979899
if (left <= 0) throw new TimeoutException(); } consumer.poll0(); } finally { sync.unregister(); } } public final long getLastIndexRead() { return consumer.lastIndexRead();
} sync.await(i); } consumer.poll0(); } finally { sync.unregister(token); } } void attemptReceive(long timeout, TimeUnit unit) throws SuspendExecution, InterruptedException, TimeoutException, EOFException { checkClosed();
112113114115116117118119120121122
if (left <= 0) throw new TimeoutException(); } consumer.poll0(); } finally { sync.unregister(token); } } public final long getLastIndexRead() { return consumer.lastIndexRead();
115116117118119120121122
public void unregister(Object token) { if (token == null) return; Condition sync = dv.getSync(); if (sync != null) sync.unregister(null); } }