- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for waiters (0.19 sec)
-
src/runtime/proc.go
// "locked" sentinel value. M's on this list remain visible to the GC // because their mp.curg is on allgs. extraM atomic.Uintptr // Number of M's in the extraM list. extraMLength atomic.Uint32 // Number of waiters in lockextra. extraMWaiters atomic.Uint32 // Number of extra M's in use by threads. extraMInUse atomic.Uint32 ) // lockextra locks the extra list and returns the list head.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 207.5K bytes - Viewed (0) -
src/database/sql/sql_test.go
saturateDone.Add(max) donePing := make(chan bool) state := 0 // waiter will be called for all queries, including // initial setup queries. The state is only assigned when // no queries are made. // // Only allow the first batch of queries to finish once the // second batch of Ping queries have finished. waiter := func(ctx context.Context) { switch state { case 0:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 18:42:28 UTC 2024 - 111.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
ExecutorService executor = newSingleThreadExecutor(); Future<V> waiter = executor.submit( new Callable<V>() { @Override public V call() throws Exception { return input.get(); } }); try { return getUninterruptibly(waiter, timeout, unit); } catch (ExecutionException e) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 29 16:29:37 UTC 2024 - 144.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
ExecutorService executor = newSingleThreadExecutor(); Future<V> waiter = executor.submit( new Callable<V>() { @Override public V call() throws Exception { return input.get(); } }); try { return getUninterruptibly(waiter, timeout, unit); } catch (ExecutionException e) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 29 16:29:37 UTC 2024 - 144.1K bytes - Viewed (0) -
tensorflow/compiler/mlir/lite/stablehlo/transforms/uniform_quantized_stablehlo_to_tfl_pass.cc
Operation* rhs_op = rhs_value.getDefiningOp(); auto filter_constant_op = dyn_cast_or_null<stablehlo::ConstantOp>(rhs_op); // Set to `nullptr` because this attribute only matters when the input is // dynamic-range quantized. const BoolAttr asymmetric_quantize_inputs = nullptr; const int lhs_rank = lhs_value.getType().cast<TensorType>().getRank(); const BoolAttr adj_x =
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Mon Apr 22 09:00:19 UTC 2024 - 99.8K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods.go
m = make(map[string]string) ) // Get all service resources from the master (via a cache), // and populate them into service environment variables. if kl.serviceLister == nil { // Kubelets without masters (e.g. plain GCE ContainerVM) don't set env vars. return m, nil } services, err := kl.serviceLister.List(labels.Everything()) if err != nil { return m, fmt.Errorf("failed to list services when setting up env vars")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 101.2K bytes - Viewed (0) -
src/net/http/server.go
// from the initial chunk of output. // // The Writers are wired together like: // // 1. *response (the ResponseWriter) -> // 2. (*response).w, a [*bufio.Writer] of bufferBeforeChunkingSize bytes -> // 3. chunkWriter.Writer (whose writeHeader finalizes Content-Length/Type) // and which writes the chunk headers, if needed -> // 4. conn.bufw, a *bufio.Writer of default (4kB) bytes, writing to ->
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 123.4K bytes - Viewed (0) -
src/database/sql/sql.go
// - removing an element (only by the caller who added it) // - taking (get + delete) a random element // // We previously used a map for this but the take of a random element // was expensive, making mapiters. This type avoids a map entirely // and just uses a slice. type connRequestSet struct { // s are the elements in the set. s []connRequestAndIndex } type connRequestAndIndex struct {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:53 UTC 2024 - 103.6K bytes - Viewed (0) -
src/reflect/value.go
mapiternext(&it) } return a[:i] } // hiter's structure matches runtime.hiter's structure. // Having a clone here allows us to embed a map iterator // inside type MapIter so that MapIters can be re-used // without doing any allocations. type hiter struct { key unsafe.Pointer elem unsafe.Pointer t unsafe.Pointer h unsafe.Pointer
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:17:41 UTC 2024 - 119.9K bytes - Viewed (0) -
cmd/site-replication.go
ExpiryLCConfig: &configStr, UpdatedAt: time.Now(), }) if err != nil { return errSRBucketMetaError(err) } } } } // Order matters from now on how the information is // synced to remote sites. // Policies should be synced first. { // Replicate IAM policies on local to all peers.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 184.3K bytes - Viewed (0)