- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 1,222 for take (0.06 sec)
-
cmd/erasure-server-pool-rebalance.go
if err != nil { rebalanceLogIf(ctx, err) } } } wk.Take() go func(setIdx int) { defer wk.Give() err := set.listObjectsToRebalance(ctx, bucket, func(entry metaCacheEntry) { wk.Take() go rebalanceEntry(entry) }, ) if err == nil || errors.Is(err, context.Canceled) { return }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Thu Sep 04 20:47:24 UTC 2025 - 28.9K bytes - Viewed (0) -
futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java
* logger.info("Done with {0}", name); * } * }, executor); * } * * <h3>How to get an instance</h3> * * <p>We encourage you to return {@code ListenableFuture} from your methods so that your users can * take advantage of the {@linkplain Futures utilities built atop the class}. The way that you will * create {@code ListenableFuture} instances depends on how you currently create {@code Future} * instances: * * <ul>
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 8K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ListenableFuture.java
* logger.info("Done with {0}", name); * } * }, executor); * } * * <h3>How to get an instance</h3> * * <p>We encourage you to return {@code ListenableFuture} from your methods so that your users can * take advantage of the {@linkplain Futures utilities built atop the class}. The way that you will * create {@code ListenableFuture} instances depends on how you currently create {@code Future} * instances: * * <ul>
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 8K bytes - Viewed (0) -
docs/bucket/lifecycle/README.md
------------|----------|------------|--------|--------------|--------------|------------------|------------------|------------------ ``` ## 3. Activate ILM versioning features This will only work with a versioned bucket, take a look at [Bucket Versioning Guide](https://docs.min.io/community/minio-object-store/administration/object-management/object-versioning.html) for more understanding. ### 3.1 Automatic removal of non current objects versions
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 9.1K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Striped.java
return array.length; } } /** * Implementation of Striped where up to 2^k stripes can be represented, using an * AtomicReferenceArray of size 2^k. To map a user key into a stripe, we take a k-bit slice of the * user key's (smeared) hashCode(). The stripes are lazily initialized and are weakly referenced. */ @VisibleForTesting static final class SmallLazyStriped<L> extends PowerOfTwoStriped<L> {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 20.6K bytes - Viewed (0) -
src/archive/tar/strconv.go
} // If seconds is negative, then perform correction. sign := "" if secs < 0 { sign = "-" // Remember sign secs = -(secs + 1) // Add a second to secs nsecs = -(nsecs - 1e9) // Take that second away from nsecs } return strings.TrimRight(fmt.Sprintf("%s%d.%09d", sign, secs, nsecs), "0") } // parsePAXRecord parses the input PAX record string into a key-value pair.
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Mon Sep 08 17:08:20 UTC 2025 - 9.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/QueuesTest.java
int elements = Queues.drain(q, buf, -1, MAX_VALUE, NANOSECONDS); assertEquals(0, elements); assertThat(buf).isEmpty(); // Free the producer thread, and give subsequent tests a clean slate. q.take(); } public void testDrain_throws() throws Exception { for (BlockingQueue<Object> q : blockingQueues()) { checkDrainThrows(q); } }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 12.2K bytes - Viewed (0) -
docs/en/docs/advanced/custom-response.md
### `HTMLResponse` { #htmlresponse } Takes some text or bytes and returns an HTML response, as you read above. ### `PlainTextResponse` { #plaintextresponse } Takes some text or bytes and returns a plain text response. {* ../../docs_src/custom_response/tutorial005.py hl[2,7,9] *} ### `JSONResponse` { #jsonresponse } Takes some data and returns an `application/json` encoded response.
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun Aug 31 09:15:41 UTC 2025 - 12.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/TestThread.java
throw new NoSuchMethodError(methodName); } @Override public void run() { assertSame(this, Thread.currentThread()); try { while (true) { Request request = requestQueue.take(); Object result; try { result = invokeMethod(request.methodName, request.arguments); } catch (ThreadDeath death) { return;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 10.8K bytes - Viewed (0) -
docs/tls/README.md
``` setx path "%path%;C:\Users\MyUser\Downloads\gnutls-3.4.9-w64\bin" ``` **Note:** PowerShell may need to be restarted for this change to take effect. #### 3.3.2 Generate a private key Run the following command to generate a private `.key` file: ``` certtool.exe --generate-privkey --outfile private.key ```
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 8.6K bytes - Viewed (0)