- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 115 for Dispatching (0.18 sec)
-
src/log/slog/value_access_benchmark_test.go
func (v *setVisitor) Bool(x bool) { v.b = x } func (v *setVisitor) Duration(x time.Duration) { v.d = x } func (v *setVisitor) Any(x any) { v.a = x } // When dispatching on all types, the "As" functions are slightly slower // than switching on the kind and then calling a function that checks // the kind again. See BenchmarkDispatch above. func (a Value) AsString() (string, bool) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 21 20:55:33 UTC 2023 - 4.3K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DefaultIncomingConnectionHandler.java
commandExecuter.executeCommand(daemonConnection, command, daemonContext, daemonStateControl); } catch (Throwable e) { LOGGER.warn(String.format("Unable to execute command %s from %s. Dispatching the failure to the daemon client", command, connection), e); daemonConnection.completed(new Failure(e)); } finally {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 7K bytes - Viewed (0) -
platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r25/BuildProgressCrossVersionSpec.groovy
} then: "build progress events must be forwarded to the attached listeners" events.assertIsABuild() } def "stops dispatching events to progress listeners when a listener fails and continues with build"() { given: goodCode() when: "launching a build" List<ProgressEvent> resultsOfFirstListener = []
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 7.7K bytes - Viewed (0) -
guava/src/com/google/common/eventbus/EventBus.java
* Returns the identifier for this event bus. * * @since 19.0 */ public final String identifier() { return identifier; } /** Returns the default executor this event bus uses for dispatching events to subscribers. */ final Executor executor() { return executor; } /** Handles the given exception thrown by a subscriber with the given context. */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jul 17 16:01:41 UTC 2023 - 12.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_filter.go
// Interface defines how the API Priority and Fairness filter interacts with the underlying system. type Interface interface { // Handle takes care of queuing and dispatching a request // characterized by the given digest. The given `noteFn` will be // invoked with the results of request classification. // The given `workEstimator` is called, if at all, after noteFn.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:35 UTC 2023 - 8K bytes - Viewed (0) -
platforms/core-configuration/graph-serialization/src/main/kotlin/org/gradle/internal/serialize/graph/codecs/BindingsBackedCodec.kt
* to the proper binding (if one is found). * * The binding (a tagged codec) is chosen based on the availability of a [Binding.encoding] for the value being encoded. * This is basically implemented as a predicate dispatching on the value type, first available Binding.encoding wins * and its [Binding.tag] is recorded in the output stream so decoding can be implemented via a fast array lookup. * * @see Binding.tag */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 04 18:56:44 UTC 2024 - 6K bytes - Viewed (0) -
platforms/core-configuration/core-serialization-codecs/src/main/kotlin/org/gradle/internal/serialize/codecs/core/UnsupportedTypesCodecs.kt
bind(unsupported<UnresolvedComponentResult>()) bind(unsupported<ArtifactResult>()) // Publishing types bind(unsupported<Publication>()) // Event dispatching infrastructure types bind(unsupported<ListenerBroadcast<*>>()) bind(unsupported<AbstractBroadcastDispatch<*>>()) // Direct build service references
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 23:09:56 UTC 2024 - 7.6K bytes - Viewed (0) -
android/guava/src/com/google/common/eventbus/EventBus.java
* Returns the identifier for this event bus. * * @since 19.0 */ public final String identifier() { return identifier; } /** Returns the default executor this event bus uses for dispatching events to subscribers. */ final Executor executor() { return executor; } /** Handles the given exception thrown by a subscriber with the given context. */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Aug 25 16:37:57 UTC 2021 - 12.8K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ListenerCallQueue.java
* * <p>Listeners are registered once via {@link #addListener} and then may be invoked by {@linkplain * #enqueue enqueueing} and then {@linkplain #dispatch dispatching} events. * * <p>The API of this class is designed to make it easy to achieve the following properties * * <ul> * <li>Multiple events for the same listener are never dispatched concurrently.
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Dec 13 19:45:20 UTC 2023 - 8.2K bytes - Viewed (0) -
src/runtime/debugcall.go
}) return ret } // debugCallWrap starts a new goroutine to run a debug call and blocks // the calling goroutine. On the goroutine, it prepares to recover // panics from the debug call, and then calls the call dispatching // function at PC dispatch. // // This must be deeply nosplit because there are untyped values on the // stack from debugCallV2. // //go:nosplit func debugCallWrap(dispatch uintptr) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 05 20:50:21 UTC 2024 - 7.1K bytes - Viewed (0)