- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 1,217 for done (0.17 sec)
-
cmd/erasure.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 16K bytes - Viewed (1) -
guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
return new TrackedRunnable() { private volatile boolean done = false; @Override public boolean isDone() { return done; } @Override public void run() { try { delay(timeoutMillis); done = true; } catch (InterruptedException ok) { } } }; }
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Thu Feb 22 17:15:24 GMT 2024 - 37.7K bytes - Viewed (0) -
src/cmd/cgo/internal/test/issue1435.go
// #include <unistd.h> // #include <sys/types.h> // // pthread_t *t = NULL; // pthread_mutex_t mu; // int nts = 0; // int all_done = 0; // // static void *aFn(void *vargp) { // int done = 0; // while (!done) { // usleep(100); // pthread_mutex_lock(&mu); // done = all_done; // pthread_mutex_unlock(&mu); // } // return NULL; // } // // void trial(int argc) { // int i;
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Fri Jul 28 21:31:41 GMT 2023 - 7.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) -
internal/grid/muxserver.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenableFutureTask.java
/** * A {@link FutureTask} that also implements the {@link ListenableFuture} interface. Unlike {@code * FutureTask}, {@code ListenableFutureTask} does not provide an overrideable {@link * FutureTask#done() done()} method. For similar functionality, call {@link #addListener}. * * <p>Few users should use this class. It is intended primarily for those who are implementing an
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 4.3K bytes - Viewed (0) -
android/guava/src/com/google/common/hash/MacHashFunction.java
checkNotDone(); checkNotNull(bytes); mac.update(bytes); } private void checkNotDone() { checkState(!done, "Cannot re-use a Hasher after calling hash() on it"); } @Override public HashCode hash() { checkNotDone(); done = true; return HashCode.fromBytesNoCopy(mac.doFinal()); } }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Feb 15 22:31:55 GMT 2022 - 3.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/DataIndexHelper.java
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 12K bytes - Viewed (0) -
cmd/bucket-replication.go
} go func() { <-p.ctx.Done() for i := 0; i < LargeWorkerCount; i++ { xioutil.SafeClose(p.lrgworkers[i]) } }() } // AddLargeWorker adds a replication worker to the static pool for large uploads. func (p *ReplicationPool) AddLargeWorker(input <-chan ReplicationWorkerOperation) { for { select { case <-p.ctx.Done(): return case oi, ok := <-input:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 112.2K bytes - Viewed (1) -
android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
} } finally { // Null out the thread field, so that we don't leak a reference to Thread, and so that // future `thread == currentThread()` calls from this thread don't incorrectly queue instead // of executing. Don't null out the latestTaskQueue field, because the work done here // may have scheduled more operations on another thread, and if those operations then
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 22.1K bytes - Viewed (0)