Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 20 for queueset (0.12 sec)

  1. api/openapi-spec/v3/apis__flowcontrol.apiserver.k8s.io__v1beta3_openapi.json

    "`handSize` is a small positive number that configures the shuffle sharding of requests into queues.  When enqueuing a request at this priority level the request's flow identifier (a string pair) is hashed and the hash value is used to shuffle the list of queues and deal a hand of the size specified here.  The request is put into one of the shortest queues in that hand. `handSize` must be no larger than `queues`, and should be significantly smaller (so that a few heavy flows do not saturate most of the...
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 08 04:18:56 UTC 2024
    - 232.7K bytes
    - Viewed (0)
  2. api/openapi-spec/v3/apis__flowcontrol.apiserver.k8s.io__v1_openapi.json

    "`handSize` is a small positive number that configures the shuffle sharding of requests into queues.  When enqueuing a request at this priority level the request's flow identifier (a string pair) is hashed and the hash value is used to shuffle the list of queues and deal a hand of the size specified here.  The request is put into one of the shortest queues in that hand. `handSize` must be no larger than `queues`, and should be significantly smaller (so that a few heavy flows do not saturate most of the...
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 08 04:18:56 UTC 2024
    - 231.7K bytes
    - Viewed (0)
  3. tensorflow/compiler/mlir/tensorflow/transforms/shape_inference.cc

      void enqueue(func::FuncOp fn) {
        LLVM_DEBUG(llvm::dbgs()
                   << "enqueue " << fn.getName() << " ("
                   << (queue_set_.count(fn) ? "already inserted" : "newly inserted")
                   << ")\n");
        if (queue_set_.insert(fn).second) queue_.push(fn);
      }
    
      // Enqueues callers on functions.
      void EnqueueCallers(func::FuncOp fn);
    
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Sat Jun 08 07:28:49 UTC 2024
    - 134.1K bytes
    - Viewed (0)
  4. src/cmd/vendor/golang.org/x/sys/windows/zsyscall_windows.go

    	if r1 == socket_error {
    		err = errnoErr(e1)
    	}
    	return
    }
    
    func WSALookupServiceBegin(querySet *WSAQUERYSET, flags uint32, handle *Handle) (err error) {
    	r1, _, e1 := syscall.Syscall(procWSALookupServiceBeginW.Addr(), 3, uintptr(unsafe.Pointer(querySet)), uintptr(flags), uintptr(unsafe.Pointer(handle)))
    	if r1 == socket_error {
    		err = errnoErr(e1)
    	}
    	return
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 04 16:19:04 UTC 2024
    - 195.8K bytes
    - Viewed (0)
  5. src/runtime/proc.go

    // available hardware parallelism and parking excessive running worker threads
    // to conserve CPU resources and power. This is not simple for two reasons:
    // (1) scheduler state is intentionally distributed (in particular, per-P work
    // queues), so it is not possible to compute global predicates on fast paths;
    // (2) for optimal thread management we would need to know the future (don't park
    // a worker thread when a new goroutine will be readied in near future).
    //
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 207.5K bytes
    - Viewed (0)
  6. pkg/printers/internalversion/printers_test.go

    							Type: flowcontrol.LimitResponseTypeQueue,
    							Queuing: &flowcontrol.QueuingConfiguration{
    								Queues:           8,
    								HandSize:         3,
    								QueueLengthLimit: 4,
    							},
    						},
    					},
    				},
    			},
    			// Columns: Name, Type, NominalConcurrencyShares, Queues, HandSize, QueueLengthLimit, Age
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 14:04:15 UTC 2024
    - 218.6K bytes
    - Viewed (0)
  7. src/cmd/go/internal/load/pkg.go

    					<-pre.sema
    					if bp != nil && loaded && err == nil && !opts.IgnoreImports {
    						pre.preloadImports(ctx, opts, bp.Imports, bp)
    					}
    				}(pkg)
    			}
    		}
    	}
    }
    
    // preloadImports queues a list of imports for preloading.
    // When preloadImports returns, some packages may not be loaded yet,
    // but loadPackageData and loadImport are always safe to call.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 28 17:00:51 UTC 2024
    - 120K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/collect/Maps.java

    /**
     * Static utility methods pertaining to {@link Map} instances (including instances of {@link
     * SortedMap}, {@link BiMap}, etc.). Also see this class's counterparts {@link Lists}, {@link Sets}
     * and {@link Queues}.
     *
     * <p>See the Guava User Guide article on <a href=
     * "https://github.com/google/guava/wiki/CollectionUtilitiesExplained#maps">{@code Maps}</a>.
     *
     * @author Kevin Bourrillion
     * @author Mike Bostock
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Sun Jun 02 13:36:19 UTC 2024
    - 159.5K bytes
    - Viewed (0)
  9. guava/src/com/google/common/collect/Maps.java

    /**
     * Static utility methods pertaining to {@link Map} instances (including instances of {@link
     * SortedMap}, {@link BiMap}, etc.). Also see this class's counterparts {@link Lists}, {@link Sets}
     * and {@link Queues}.
     *
     * <p>See the Guava User Guide article on <a href=
     * "https://github.com/google/guava/wiki/CollectionUtilitiesExplained#maps">{@code Maps}</a>.
     *
     * @author Kevin Bourrillion
     * @author Mike Bostock
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Apr 24 19:38:27 UTC 2024
    - 165.9K bytes
    - Viewed (0)
  10. doc/go1.17_spec.html

    <a href="#Length_and_capacity"><code>cap</code></a> and
    <a href="#Length_and_capacity"><code>len</code></a>
    by any number of goroutines without further synchronization.
    Channels act as first-in-first-out queues.
    For example, if one goroutine sends values on a channel
    and a second goroutine receives them, the values are
    received in the order sent.
    </p>
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Apr 11 20:22:45 UTC 2024
    - 211.6K bytes
    - Viewed (0)
Back to top