- Sort Score
- Result 10 results
- Languages All
Results 131 - 140 of 412 for dispatchTo (0.26 sec)
-
src/runtime/asm_arm.s
DISPATCH(runtime·call2048, 2048) DISPATCH(runtime·call4096, 4096) DISPATCH(runtime·call8192, 8192) DISPATCH(runtime·call16384, 16384) DISPATCH(runtime·call32768, 32768) DISPATCH(runtime·call65536, 65536) DISPATCH(runtime·call131072, 131072) DISPATCH(runtime·call262144, 262144) DISPATCH(runtime·call524288, 524288) DISPATCH(runtime·call1048576, 1048576) DISPATCH(runtime·call2097152, 2097152)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Feb 23 21:00:52 UTC 2024 - 32.1K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/classpath/InstrumentedClosuresTracker.java
* to the current closures chain and can potentially be intercepted. The implementation must ensure that all the closures in the scope are processed in a way that * ensures call interception if a call is dispatched to them. */ @NonNullApi public interface InstrumentedClosuresTracker {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Aug 11 12:31:52 UTC 2023 - 1.6K bytes - Viewed (0) -
docs/contribute/concurrency.md
So we have a dedicated thread for every socket that just reads frames and dispatches them. The reader thread must never run application-layer code. Otherwise one slow stream can hold up the entire connection.
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Feb 06 16:35:36 UTC 2022 - 7K bytes - Viewed (0) -
platforms/ide/tooling-api/src/test/groovy/org/gradle/tooling/internal/consumer/async/DefaultAsyncConsumerActionExecutorTest.groovy
} def "runs action asynchronously"() { when: async { connection.run(action, handler) instant.dispatched } then: 1 * actionExecuter.run(action) >> { thread.blockUntil.dispatched instant.actionStarted return "result" } 1 * handler.onComplete("result") >> { instant.resultReceived
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 2.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/LoomTest.kt
@BeforeEach fun setUp(server: MockWebServer) { platform.assumeLoom() this.server = server client = clientTestRule.newClientBuilder() .dispatcher(Dispatcher(newVirtualThreadPerTaskExecutor())) .build() } private fun newVirtualThreadPerTaskExecutor(): ExecutorService {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java
queue.enqueue(incrementingEvent(counters, listener, 3)); queue.enqueue(incrementingEvent(counters, listener, 4)); assertEquals(0, counters.size()); queue.dispatch(); assertEquals(multiset(listener, 4), counters); } public void testEnqueueAndDispatch_multipleListeners() { Object listener1 = new Object(); ListenerCallQueue<Object> queue = new ListenerCallQueue<>();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Feb 09 22:57:07 UTC 2022 - 8.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java
queue.enqueue(incrementingEvent(counters, listener, 3)); queue.enqueue(incrementingEvent(counters, listener, 4)); assertEquals(0, counters.size()); queue.dispatch(); assertEquals(multiset(listener, 4), counters); } public void testEnqueueAndDispatch_multipleListeners() { Object listener1 = new Object(); ListenerCallQueue<Object> queue = new ListenerCallQueue<>();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Feb 09 22:57:07 UTC 2022 - 8.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/Locks.kt
import kotlin.contracts.InvocationKind import kotlin.contracts.contract import okhttp3.Dispatcher import okhttp3.internal.http2.Http2Connection import okhttp3.internal.http2.Http2Stream import okhttp3.internal.http2.Http2Writer /** * Centralisation of central locks according to docs/contribute/concurrency.md */ internal object Locks { inline fun <T> Dispatcher.withLock(action: () -> T): T {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 2.1K bytes - Viewed (0) -
platforms/ide/tooling-api/src/test/groovy/org/gradle/tooling/internal/consumer/DefaultPhasedBuildActionExecuterTest.groovy
start { thread.blockUntil.dispatched instant.resultAvailable adaptedHandler.onComplete(null) } } handler.onComplete(null) >> { instant.resultReceived } when: async { executer.run(handler) instant.dispatched thread.blockUntil.resultReceived }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt
this.taskRunner = okHttpClient.taskRunner } /** * Sets the dispatcher used to set policy and execute asynchronous requests. Must not be null. */ fun dispatcher(dispatcher: Dispatcher) = apply { this.dispatcher = dispatcher } /** * Sets the connection pool used to recycle HTTP and HTTPS connections. *
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 06 04:21:33 UTC 2024 - 52K bytes - Viewed (0)