- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 587 for blocked (0.16 sec)
-
src/os/fifo_test.go
} // Per https://pubs.opengroup.org/onlinepubs/9699919799/functions/open.html#tag_16_357_03: // // - “If O_NONBLOCK is clear, an open() for reading-only shall block the // calling thread until a thread opens the file for writing. An open() for // writing-only shall block the calling thread until a thread opens the file // for reading.” // // In order to unblock both open calls, we open the two ends of the FIFO
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 19 11:47:23 UTC 2024 - 6.1K bytes - Viewed (0) -
internal/grid/muxserver.go
} default: m.disconnect("handler blocked", true) } } func (m *muxServer) unblockSend(seq uint32) { if !m.checkSeq(seq) { return } m.recvMu.Lock() defer m.recvMu.Unlock() if m.outBlock == nil { // Closed return } select { case m.outBlock <- struct{}{}: default: gridLogIf(m.ctx, errors.New("output unblocked overflow")) } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 9.7K bytes - Viewed (0) -
src/runtime/tracestatus.go
// state but needs to present itself as preempted to the // garbage collector. In these cases, we're not going to // emit an event, and we want these goroutines to appear in // the final trace as if they're running, not blocked. tgs = traceGoWaiting if status == _Gwaiting && wr.isWaitingForGC() { tgs = traceGoRunning } case _Gdead: throw("tried to trace dead goroutine") default:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 17:03:35 UTC 2024 - 7.2K 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/mgc.go
// this before waking blocked assists. atomic.Store(&gcBlackenEnabled, 0) // Notify the CPU limiter that GC assists will now cease. gcCPULimiter.startGCTransition(false, now) // Wake all blocked assists. These will run when we // start the world again. gcWakeAllAssists() // Likewise, release the transition lock. Blocked // workers and assists will run when we start the
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 16:25:21 UTC 2024 - 62K 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) -
maven-compat/src/main/java/org/apache/maven/artifact/repository/LegacyLocalRepositoryManager.java
} public void setMirroredRepositories(List<ArtifactRepository> mirroredRepositories) {} public boolean isBlocked() { return false; } public void setBlocked(boolean blocked) {} }
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Feb 28 07:40:37 UTC 2024 - 12.2K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/telemetry/internal/crashmonitor/monitor.go
pcs = pcs[:min(len(pcs), 16)] if len(pcs) == 0 { // This can occur if all goroutines are idle, as when // caught in a deadlock, or killed by an async signal // while blocked. // // TODO(adonovan): consider how to report such // situations. Reporting a goroutine in [sleep] or // [select] state could be quite confusing without // further information about the nature of the crash,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 04 17:57:25 UTC 2024 - 7.6K bytes - Viewed (0) -
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)