- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 4,874 for Done (0.14 sec)
-
android/guava/src/com/google/common/collect/AbstractIterator.java
*/ @CanIgnoreReturnValue @CheckForNull protected final T endOfData() { state = State.DONE; return null; } @Override public final boolean hasNext() { checkState(state != State.FAILED); switch (state) { case DONE: return false; case READY: return true; default: } return tryToComputeNext(); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Fri Mar 18 02:04:10 GMT 2022 - 6.4K bytes - Viewed (0) -
internal/grid/muxclient.go
}() return } select { case <-m.ctx.Done(): if debugPrint { fmt.Println("Client sending disconnect to mux", m.MuxID) } m.addErrorNonBlockingClose(internalResp, context.Cause(m.ctx)) errState = true continue case req, ok := <-requests: if !ok { // Done send EOF if debugPrint { fmt.Println("Client done, sending EOF to mux", m.MuxID) } msg := message{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
internal/dsync/drwmutex.go
done = true } } case <-ctx.Done(): // Capture timedout locks as failed or took too long locksFailed++ if locksFailed > tolerance { // We know that we are not going to get the lock anymore, // so exit out and release any locks that did get acquired done = true } } if done { break } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0) -
guava/src/com/google/common/collect/AbstractIterator.java
*/ @CanIgnoreReturnValue @CheckForNull protected final T endOfData() { state = State.DONE; return null; } @Override public final boolean hasNext() { checkState(state != State.FAILED); switch (state) { case DONE: return false; case READY: return true; default: } return tryToComputeNext(); }
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Fri Mar 18 02:04:10 GMT 2022 - 6.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
* that returns a {@code ClosingFuture} to its value. The function can use a {@link * DeferredCloser} to capture objects to be closed when the pipeline is done (other than those * captured by the returned {@link ClosingFuture}). * * <p>If this {@code ClosingFuture} succeeds, the derived one will be equivalent to the one * returned by the function. *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 98.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/CombinedFuture.java
/* * If the output future is done, then it won't need to interrupt the task later, so it can clear * its reference to it. * * If the output future is *not* done, then the task field will be cleared after the task runs * or after the output future is done, whichever comes first. */ if (reason == OUTPUT_FUTURE_DONE) { this.task = null; } } @Override
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 6.8K bytes - Viewed (0) -
internal/config/lambda/target/lazyinit.go
type lazyInit struct { done uint32 m sync.Mutex } func (l *lazyInit) Do(f func() error) error { if atomic.LoadUint32(&l.done) == 0 { return l.doSlow(f) } return nil } func (l *lazyInit) doSlow(f func() error) error { l.m.Lock() defer l.m.Unlock() if atomic.LoadUint32(&l.done) == 0 { if err := f(); err != nil { return err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 07 16:12:41 GMT 2023 - 1.3K bytes - Viewed (0) -
guava/src/com/google/common/base/AbstractIterator.java
protected AbstractIterator() {} private enum State { READY, NOT_READY, DONE, FAILED, } @CheckForNull private T next; @CheckForNull protected abstract T computeNext(); @CanIgnoreReturnValue @CheckForNull protected final T endOfData() { state = State.DONE; return null; } @Override public final boolean hasNext() {
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Fri Jul 09 17:31:04 GMT 2021 - 2.5K bytes - Viewed (0) -
guava-testlib/src/com/google/common/testing/GcFinalization.java
do { System.runFinalization(); if (predicate.isDone()) { return; } CountDownLatch done = new CountDownLatch(1); createUnreachableLatchFinalizer(done); await(done); if (predicate.isDone()) { return; } } while (System.nanoTime() - deadline < 0); throw formatRuntimeException(
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Thu Feb 22 17:40:56 GMT 2024 - 11.6K bytes - Viewed (0) -
cmd/notification.go
wg.Add(1) go func(ctx context.Context, peerChannel <-chan MetricV2, wg *sync.WaitGroup) { defer wg.Done() for { select { case m, ok := <-peerChannel: if !ok { return } select { case ch <- m: case <-ctx.Done(): return } case <-ctx.Done(): return } } }(ctx, peerChannels[index], &wg) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 12 18:13:36 GMT 2024 - 44.5K bytes - Viewed (0)