- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 166 for blocked (0.28 sec)
-
src/runtime/os_windows.go
// Don't profile ourselves. continue } lock(&mp.threadLock) // Do not profile threads blocked on Notes, // this includes idle worker threads, // idle timer thread, idle heap scavenger, etc. if mp.thread == 0 || mp.profilehz == 0 || mp.blocked { unlock(&mp.threadLock) continue } // Acquire our own handle to the thread. var thread uintptr
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 22:55:25 UTC 2024 - 41.5K bytes - Viewed (0) -
src/os/signal/doc.go
entirely. If the program is started with a non-empty signal mask, some signals will be explicitly unblocked as described above. If Notify is called for a blocked signal, it will be unblocked. If, later, Reset is called for that signal, or Stop is called on all channels passed to Notify for that signal, the signal will once again be blocked. # SIGPIPE When a Go program writes to a broken pipe, the kernel will raise a SIGPIPE signal.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 18:11:00 UTC 2024 - 11K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller_test.go
}() // Start controller wg.Add(1) go func() { defer wg.Done() stopReason := myController.Run(testContext) require.ErrorIs(t, stopReason, context.Canceled) }() // The controller is blocked because the reconcile function sends on an // unbuffered channel. require.False(t, myController.HasSynced()) // Wait for all enqueued reconciliations require.NoError(t, waitForReconcile(initialObject))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 12 18:58:24 UTC 2024 - 16.1K bytes - Viewed (0) -
src/runtime/pprof/pprof.go
// the program began (including garbage-collected bytes). // // # Block profile // // The block profile tracks time spent blocked on synchronization primitives, // such as [sync.Mutex], [sync.RWMutex], [sync.WaitGroup], [sync.Cond], and // channel send/receive/select. // // Stack traces correspond to the location that blocked (for example, // [sync.Mutex.Lock]). //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:52:17 UTC 2024 - 30.6K bytes - Viewed (0) -
api/maven-api-settings/src/main/mdo/settings.mdo
@since Maven 3. </description> </field> <field> <name>blocked</name> <version>1.2.0+</version> <type>boolean</type> <defaultValue>false</defaultValue> <description> <![CDATA[ Whether this mirror should be blocked from any download request but fail the download process, explaining why.
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Sat Feb 17 18:40:11 UTC 2024 - 33.3K bytes - Viewed (0) -
src/runtime/traceruntime.go
tl.eventWriter(traceGoRunning, traceProcRunning).commit(traceEvGCMarkAssistEnd) } // GoCreate emits a GoCreate event. func (tl traceLocker) GoCreate(newg *g, pc uintptr, blocked bool) { newg.trace.setStatusTraced(tl.gen) ev := traceEvGoCreate if blocked { ev = traceEvGoCreateBlocked } tl.eventWriter(traceGoRunning, traceProcRunning).commit(ev, traceArg(newg.goid), tl.startPC(pc), tl.stack(2)) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 22:31:00 UTC 2024 - 25.7K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/BlockingHttpServer.java
* Waits for the request to be received and blocked. */ void waitUntilBlocked(); /** * Unblock the request. */ void release(); } /** * Allows the test to synchronise with and unblock requests. */ public interface BlockingHandler { /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 21.7K bytes - Viewed (0) -
android/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: Mon Jun 10 19:21:11 UTC 2024 - 37.7K bytes - Viewed (0) -
src/runtime/chan.go
for !glist.empty() { gp := glist.pop() gp.schedlink = 0 goready(gp, 3) } } // empty reports whether a read from c would block (that is, the channel is // empty). It is atomically correct and sequentially consistent at the moment // it returns, but since the channel is unlocked, the channel may become // non-empty immediately afterward. func empty(c *hchan) bool { // c.dataqsiz is immutable. if c.dataqsiz == 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:50 UTC 2024 - 25.9K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/event/DefaultListenerManagerTest.groovy
sleep 1000 // Try to get broadcaster, should not block def broadcaster = manager.getBroadcaster(TestBazListener) // Notify broadcaster, should not block broadcaster.baz() } as TestFooListener def listener2 = { sleep 20 // Try to remove listener, should be blocked until listener 1 is done manager.removeListener(listener1)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 02:21:10 UTC 2024 - 29.1K bytes - Viewed (0)