- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 587 for blocked (0.39 sec)
-
guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
* state: BLOCKED, WAITING, or TIMED_WAITING. */ void waitForThreadToEnterWaitState(Thread thread, long timeoutMillis) { long startTime = System.nanoTime(); for (; ; ) { Thread.State s = thread.getState(); if (s == Thread.State.BLOCKED || s == Thread.State.WAITING || s == Thread.State.TIMED_WAITING) return;
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 17:15:24 UTC 2024 - 37.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/TestThread.java
} /** * Asserts that a prior call that had caused this thread to block or wait has since returned * normally. */ public void assertPriorCallReturns(@Nullable String methodName) throws Exception { assertEquals(null, getResponse(methodName).getResult()); } /** * Asserts that a prior call that had caused this thread to block or wait has since returned the * expected boolean value. */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 10.8K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DefaultDaemonConnection.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:51:37 UTC 2024 - 16K bytes - Viewed (0) -
src/runtime/cpuprof.go
// //go:nosplit //go:nowritebarrierrec func (p *cpuProfile) addNonGo(stk []uintptr) { // Simple cas-lock to coordinate with SetCPUProfileRate. // (Other calls to add or addNonGo should be blocked out // by the fact that only one SIGPROF can be handled by the // process at a time. If not, this lock will serialize those too. // The use of timer_create(2) on Linux to request process-targeted
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 8.5K bytes - Viewed (0) -
src/os/signal/signal_test.go
// nothing to read - good } select { case s := <-c2: t.Errorf("unexpected signal %v", s) default: // nothing to read - good } // One or both of the signals may have been blocked for this process // by the calling process. // Discard any queued signals now to avoid interfering with other tests. Notify(c1, syscall.SIGWINCH) Notify(c2, syscall.SIGHUP) quiesce() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Nov 09 15:34:56 UTC 2023 - 27.2K bytes - Viewed (0) -
src/runtime/mgcmark.go
// condition. // //go:nowritebarrierrec func gcFlushBgCredit(scanWork int64) { if work.assistQueue.q.empty() { // Fast path; there are no blocked assists. There's a // small window here where an assist may add itself to // the blocked queue and park. If that happens, we'll // just get it on the next flush. gcController.bgScanCredit.Add(scanWork) return }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 18 21:25:11 UTC 2024 - 52.5K bytes - Viewed (0) -
internal/grid/grid_test.go
// Check that remote is canceled. <-serverCanceled close(nowBlocking) } // testServerStreamPingRunning will test if server and client handle ping even when blocked. func testServerStreamPingRunning(t *testing.T, local, remote *Manager, inCap int, blockResp, blockReq bool) { defer testlogger.T.SetErrorTB(t)() errFatal := func(err error) { t.Helper() if err != nil { t.Fatal(err) } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 36.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/TestThread.java
} /** * Asserts that a prior call that had caused this thread to block or wait has since returned * normally. */ public void assertPriorCallReturns(@Nullable String methodName) throws Exception { assertEquals(null, getResponse(methodName).getResult()); } /** * Asserts that a prior call that had caused this thread to block or wait has since returned the * expected boolean value. */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 10.8K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/ExpectMaxNConcurrentRequests.java
} } finally { lock.unlock(); } return handler; } /** * Called when the expected requests have been received and are now blocked waiting to be released. * Subclasses may choose to release some or all of the requests. */ protected void onExpectedRequestsReceived(BlockingHttpServer.BlockingHandler handler, int yetToBeReceived) { }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 14.4K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java
* specified access policy. * * @param capacity the capacity of this queue * @param fair if {@code true} then queue accesses for threads blocked on insertion or removal, * are processed in FIFO order; if {@code false} the access order is unspecified. * @throws IllegalArgumentException if {@code capacity} is less than 1 */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Apr 19 19:24:36 UTC 2023 - 22.5K bytes - Viewed (0)