- Sort Score
- Num 10 results
- Language All
Results 251 - 260 of 354 for Futures (0.07 seconds)
-
internal/logger/target/kafka/kafka.go
// stop the replay go-routine. if h.store != nil { h.storeCtxCancel() } // Set logch to nil and close it. // This will block all Send operations, // and finish the existing ones. // All future ones will be discarded. h.logChMu.Lock() xioutil.SafeClose(h.logCh) h.logCh = nil h.logChMu.Unlock() if h.producer != nil { h.producer.Close() h.client.Close() }Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 10.2K bytes - Click Count (0) -
android/guava/src/com/google/common/hash/Hashing.java
* MD5 (128 hash bits) hash function and the given secret key. * * <p>If you are designing a new system that needs HMAC, prefer {@link #hmacSha256} or other * future-proof algorithms <a * href="https://datatracker.ietf.org/doc/html/rfc6151#section-2.3">over {@code hmacMd5}</a>. * * @param key the secret key
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Jul 17 15:26:41 GMT 2025 - 29.8K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/OkHttpClient.kt
* if you are writing a application that needs to aggressively release unused resources you may do * so. * * Shutdown the dispatcher's executor service with [shutdown()][ExecutorService.shutdown]. This will * also cause future calls to the client to be rejected. * * ```java * client.dispatcher().executorService().shutdown(); * ``` * * Clear the connection pool with [evictAll()][ConnectionPool.evictAll]. Note that the connection
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Oct 07 21:55:03 GMT 2025 - 51.4K bytes - Click Count (0) -
docs/pt/docs/_llm-test.md
Os testes adicionados aqui serão vistos por todos os autores dos prompts específicos de idioma. Use da seguinte forma: * Tenha um prompt específico do idioma – `docs/{language code}/llm-prompt.md`.Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Wed Dec 17 10:17:03 GMT 2025 - 12.4K bytes - Click Count (0) -
misc/cgo/gmp/gmp.go
It is much more difficult for the C world to have pointers into the Go world, because the Go garbage collector is unaware of the memory allocated by C. The most important consideration is not to constrain future implementations, so the rule is that Go code can hand a Go pointer to C code but must separately arrange for Go to hang on to a reference to the pointer until C is done with it. */ package gmp /*
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Mon Apr 11 16:34:30 GMT 2022 - 9.5K bytes - Click Count (0) -
CHANGELOG/CHANGELOG-1.13.md
- The CSI driver-registrar external sidecar container v1.0.0-rc2 is known to take up to 1 minute to start in some cases. We expect this issue to be resolved in a future release of the sidecar container. For verification, please see the release notes of future releases of the external sidecar container. ([#76](https://github.com/kubernetes-csi/driver-registrar/issues/76))
Created: Fri Dec 26 09:05:12 GMT 2025 - Last Modified: Thu May 05 13:44:43 GMT 2022 - 273.1K bytes - Click Count (0) -
build-logic/documentation/src/main/groovy/gradlebuild/docs/GradleUserManualPlugin.java
return excludedPackages; } // TODO: This doesn't really make sense to be part of the user manual generation, but it's so tied up into it // it's left here for a future project. private void generateDefaultImports(Project project, TaskContainer tasks, GradleDocumentationExtension extension) { List<String> excludedPackages = getDefaultExcludedPackages();Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Thu Dec 04 14:26:28 GMT 2025 - 19.3K bytes - Click Count (0) -
compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/DefaultWagonManager.java
} finally { if (downloadMonitor != null) { wagon.removeTransferListener(downloadMonitor); } } // Pre-store the checksums as any future puts will overwrite them for (String extension : checksums.keySet()) { ChecksumObserver observer = checksums.get(extension); sums.put(extension, observer.getActualChecksum());Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Sat Apr 05 11:52:05 GMT 2025 - 29.9K bytes - Click Count (0) -
src/archive/zip/reader.go
// (as defined by [filepath.IsLocal]) or a name containing backslashes // and the GODEBUG environment variable contains `zipinsecurepath=0`, // OpenReader returns the reader with an ErrInsecurePath error. // A future version of Go may introduce this behavior by default. // Programs that want to accept non-local names can ignore // the ErrInsecurePath error and use the returned reader. func OpenReader(name string) (*ReadCloser, error) {
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Tue Mar 11 22:19:38 GMT 2025 - 28.4K bytes - Click Count (0) -
cmd/endpoint-ellipses.go
} return err } for _, arg := range args { if !ellipses.HasEllipses(arg) && len(args) > 1 { // TODO: support SNSD deployments to be decommissioned in future return fmt.Errorf("all args must have ellipses for pool expansion (%w) args: %s", errInvalidArgument, args) } setArgs, err = GetAllSets(setDriveCount, arg) if err != nil { return err }Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 14.7K bytes - Click Count (0)