- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 27 for donec (0.2 sec)
-
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
* done. */ public static final class DeferredCloser { @RetainedWith private final CloseableList list; DeferredCloser(CloseableList list) { this.list = list; } /** * Captures an object to be closed when a {@link ClosingFuture} pipeline is done. *
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) -
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 Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 112.2K bytes - Viewed (1) -
guava-tests/test/com/google/common/io/testdata/alice_in_wonderland.txt
repeated in a wondering tone. `Why, what are YOUR shoes done with?' said the Gryphon. `I mean, what makes them so shiny?' Alice looked down at them, and considered a little before she gave her answer. `They're done with blacking, I believe.' `Boots and shoes under the sea,' the Gryphon went on in a deep voice, `are done with a whiting. Now you know.'
Plain Text - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Mon Oct 29 21:35:03 GMT 2012 - 145.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
/** * Test the case where the futures are fulfilled prior to constructing the ListFuture. There was a * bug where the loop that connects a Listener to each of the futures would die on the last * loop-check as done() on ListFuture nulled out the variable being looped over (the list of * futures). */ public void testAllAsList_doneFutures() throws Exception { // Create input and output
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 144.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/testdata/alice_in_wonderland.txt
repeated in a wondering tone. `Why, what are YOUR shoes done with?' said the Gryphon. `I mean, what makes them so shiny?' Alice looked down at them, and considered a little before she gave her answer. `They're done with blacking, I believe.' `Boots and shoes under the sea,' the Gryphon went on in a deep voice, `are done with a whiting. Now you know.'
Plain Text - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Fri Apr 21 02:27:51 GMT 2017 - 145.2K bytes - Viewed (0) -
cmd/object-handlers_test.go
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 160K bytes - Viewed (0) -
cmd/site-replication.go
wg.Add(1) if v.DeploymentID == globalDeploymentID() { go func() { defer wg.Done() err := c.RemoveRemoteTargetsForEndpoint(ctx, objectAPI, rmvEndpoints, false) errs[globalDeploymentID()] = err }() continue } go func(pi madmin.PeerInfo) { defer wg.Done() admClient, err := c.getAdminClient(ctx, pi.DeploymentID) if err != nil {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 25 15:50:16 GMT 2024 - 184.1K bytes - Viewed (1) -
guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
/** * Test the case where the futures are fulfilled prior to constructing the ListFuture. There was a * bug where the loop that connects a Listener to each of the futures would die on the last * loop-check as done() on ListFuture nulled out the variable being looped over (the list of * futures). */ public void testAllAsList_doneFutures() throws Exception { // Create input and output
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 144.5K bytes - Viewed (0) -
maven-core/src/test/resources/apiv4-repo/org/codehaus/plexus/plexus-utils/1.1/plexus-utils-1.1.jar
consumeLine(String); } org/codehaus/plexus/util/cli/StreamFeeder.class package org.codehaus.plexus.util.cli; public synchronized class StreamFeeder extends Thread { private java.io.InputStream input; private java.io.OutputStream output; private boolean done; public void StreamFeeder(java.io.InputStream, java.io.OutputStream); public void run(); public void close(); public boolean isDone(); private void feed() throws java.io.IOException; } org/codehaus/plexus/util/cli/StreamPumper.class package org.co...
Archive - Registered: Sun Apr 21 03:35:09 GMT 2024 - Last Modified: Sun Oct 02 08:41:25 GMT 2022 - 164.6K bytes - Viewed (0) -
maven-core/src/test/remote-repo/org/codehaus/plexus/plexus-utils/1.1/plexus-utils-1.1.jar
consumeLine(String); } org/codehaus/plexus/util/cli/StreamFeeder.class package org.codehaus.plexus.util.cli; public synchronized class StreamFeeder extends Thread { private java.io.InputStream input; private java.io.OutputStream output; private boolean done; public void StreamFeeder(java.io.InputStream, java.io.OutputStream); public void run(); public void close(); public boolean isDone(); private void feed() throws java.io.IOException; } org/codehaus/plexus/util/cli/StreamPumper.class package org.co...
Archive - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Fri Oct 23 23:48:02 GMT 2009 - 164.6K bytes - Viewed (0)