- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 4,874 for Done (0.13 sec)
-
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-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Feb 22 17:15:24 GMT 2024 - 37.2K bytes - Viewed (0) -
buildscripts/verify-healing-empty-erasure-set.sh
done "${MINIO[@]}" --address ":$((start_port + 1))" $args >"${WORK_DIR}/dist-minio-server1.log" 2>&1 & pid1=$! disown ${pid1}
Shell Script - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 21:55:41 GMT 2024 - 3.2K 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) -
ci/official/containers/linux_arm64/build.sh
Shell Script - Registered: Tue May 07 12:40:20 GMT 2024 - Last Modified: Fri Nov 03 13:38:49 GMT 2023 - 2.3K bytes - Viewed (0) -
internal/dsync/dsync_test.go
dm.Unlock(context.Background()) dm.Lock(id, source) time.Sleep(time.Duration(10+(rand.Float32()*50)) * time.Millisecond) dm.Unlock(context.Background()) } // Test two locks for same resource, one succeeds, one fails (after timeout) func TestTwoSimultaneousLocksForSameResource(t *testing.T) { dm1st := NewDRWMutex(ds, "aap") dm2nd := NewDRWMutex(ds, "aap") dm1st.Lock(id, source)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 24 03:49:07 GMT 2022 - 11K bytes - Viewed (0) -
cmd/metacache-walk.go
return err } ctx, done, err := p.TrackDiskHealth(ctx, storageMetricWalkDir, opts.Bucket, opts.BaseDir) if err != nil { return err } defer done(&err) return p.storage.WalkDir(ctx, opts, wr) } // WalkDir will traverse a directory and return all entries found. // On success a meta cache stream will be returned, that should be closed when done.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 12.4K 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) -
okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt
// We need new data from upstream. while (true) { val upstreamPos = ******@****.***amPos if (sourcePos != upstreamPos) break // No more data upstream. We're done. if (complete) return -1L // Another thread is already reading. Wait for that. if (upstreamReader != null) { timeout.waitUntilNotified(this@Relay)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.8K bytes - Viewed (0) -
RELEASE_BRANCHES.md
## Feature implementation Release managers will continue to have a final say in what gets merged or not, unless directed by the TOC. See the next section if the implementation is done, but a bug is being addressed. * Any code that changes feature functionality must be done within 2 weeks of the release branch cutting. Even then it is at the discretion of the release managers if PRs will be accepted and merged into the release branch.
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Nov 12 23:27:43 GMT 2021 - 3.9K bytes - Viewed (0)