- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 115 for Dispatching (0.23 sec)
-
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/Connection.java
* However, the implementations: * <ul> * <li>should allow separate threads for dispatching and receiving, i.e. single thread that dispatches * and a different single thread that receives should be perfectly safe</li> * <li>should allow stopping or requesting stopping from a different thread than receiving/dispatching</li> * <li>don't guarantee allowing multiple threads dispatching</li> * </ul> */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 1.4K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/SynchronizedDispatchConnection.java
if (dispatching) { // Safety check: dispatching a message should not cause the thread to dispatch another message (eg should not do any logging) throw new IllegalStateException("This thread is already dispatching a message."); } dispatching = true; try { delegate.dispatch(message); delegate.flush(); } finally {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jan 26 14:58:23 UTC 2024 - 3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/request/mutating_work_estimator.go
// be dispatched, we are not dispatching any other request until // we accumulate enough seats to dispatch the nominated one, even // if currently unoccupied seats would allow for dispatching some // other requests in the meantime // As a consequence of these, the wider the request, the more capacity // will effectively be blocked and unused during dispatching and // executing this request. //
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 17 19:26:52 UTC 2023 - 6K bytes - Viewed (0) -
android/guava/src/com/google/common/eventbus/Dispatcher.java
protected Queue<Event> initialValue() { return Queues.newArrayDeque(); } }; /** Per-thread dispatch state, used to avoid reentrant event dispatching. */ private final ThreadLocal<Boolean> dispatching = new ThreadLocal<Boolean>() { @Override protected Boolean initialValue() { return false; } }; @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Dec 15 19:31:54 UTC 2023 - 7.3K bytes - Viewed (0) -
guava/src/com/google/common/eventbus/Dispatcher.java
protected Queue<Event> initialValue() { return Queues.newArrayDeque(); } }; /** Per-thread dispatch state, used to avoid reentrant event dispatching. */ private final ThreadLocal<Boolean> dispatching = new ThreadLocal<Boolean>() { @Override protected Boolean initialValue() { return false; } }; @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Dec 15 19:31:54 UTC 2023 - 7.3K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/client/DaemonClientConnection.java
dispatchLock.unlock(); } } catch (MessageIOException e) { if (suspect) { LOG.debug("Problem dispatching message to the daemon.", e); } else { LOG.debug("Problem dispatching message to the daemon. Performing 'on failure' operation..."); if (!hasReceived && staleAddressDetector.maybeStaleAddress(e)) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 30 06:43:50 UTC 2024 - 4.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/interface.go
// Complete returns a QueueSet configured by the given // dispatching configuration. Complete(DispatchingConfig) QueueSet } // QueueSet is the abstraction for the queuing and dispatching // functionality of one non-exempt priority level. It covers the // functionality described in the "Assignment to a Queue", "Queuing", // and "Dispatching" sections of
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 26 12:55:23 UTC 2023 - 6.4K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/dispatch/DispatchFailureHandler.java
*/ package org.gradle.internal.dispatch; public interface DispatchFailureHandler<T> { /** * Called when a message could not be dispatched. This method can throw an exception to abort further dispatching. */ void dispatchFailed(T message, Throwable failure);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 892 bytes - Viewed (0) -
android/guava/src/com/google/common/eventbus/Subscriber.java
import java.lang.reflect.Method; import java.util.concurrent.Executor; import javax.annotation.CheckForNull; /** * A subscriber method on a specific object, plus the executor that should be used for dispatching * events to it. * * <p>Two subscribers are equivalent when they refer to the same method on the same object (not * class). This property is used to ensure that no subscriber method is registered more than once. *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Oct 06 00:47:57 UTC 2021 - 4.7K bytes - Viewed (0) -
guava/src/com/google/common/eventbus/Subscriber.java
import java.lang.reflect.Method; import java.util.concurrent.Executor; import javax.annotation.CheckForNull; /** * A subscriber method on a specific object, plus the executor that should be used for dispatching * events to it. * * <p>Two subscribers are equivalent when they refer to the same method on the same object (not * class). This property is used to ensure that no subscriber method is registered more than once. *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Oct 06 00:47:57 UTC 2021 - 4.7K bytes - Viewed (0)