- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 232 for defBlock (0.13 sec)
-
src/runtime/rwmutex.go
const rwmutexMaxReaders = 1 << 30 // rlock locks rw for reading. func (rw *rwmutex) rlock() { // The reader must not be allowed to lose its P or else other // things blocking on the lock may consume all of the Ps and // deadlock (issue #20903). Alternatively, we could drop the P // while sleeping. acquireLockRankAndM(rw.readRank) lockWithRankMayAcquire(&rw.rLock, getLockRank(&rw.rLock)) if rw.readerCount.Add(1) < 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 22 14:29:04 UTC 2024 - 5K bytes - Viewed (0) -
src/runtime/proc.go
// scheduler state, so we didn't gcstopm in findRunnable, but // also don't want to allow new goroutines to run. // // Deadlock here rather than in the findRunnable loop so if // findRunnable is stuck in a loop we don't perturb that // either. lock(&deadlock) lock(&deadlock) } // This thread is going to run a goroutine and is not spinning anymore,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 207.5K bytes - Viewed (0) -
src/runtime/os_windows.go
// CreateThread may fail if called // concurrently with ExitProcess. If this // happens, just freeze this thread and let // the process exit. See issue #18253. lock(&deadlock) lock(&deadlock) } print("runtime: failed to create new OS thread (have ", mcount(), " already; errno=", getlasterror(), ")\n") throw("runtime.newosproc") }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 22:55:25 UTC 2024 - 41.5K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/ProjectLeaseRegistry.java
/** * Runs the given action and disallows the current thread from attempting to acquire or release any project locks. * Applying this constraint means that the thread will not block waiting for a project lock and cause a deadlock. * This constraint also means that it does not need to release its project locks when it needs to block while waiting for some operation to complete. *
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 02:21:10 UTC 2024 - 5.4K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/operations/DefaultBuildOperationQueue.java
// block waiting for access to some other project, which means it can proceed even if some other thread is waiting for a project lock it // holds without causing a deadlock. This in turn implies that this thread does not need to release the project locks it holds while
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jan 31 15:18:20 UTC 2023 - 10.4K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/ChainingHttpHandler.java
requestCompleted(outcome); } } finally { httpExchange.close(); } } // Dump all JVMs' threads on the machine to troubleshoot deadlock issues // We observed jstack hanging on windows, so for now we only enable it for Linux private void dumpThreadsUponTimeout(String stacktrace) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 10.5K bytes - Viewed (0) -
src/runtime/lock_js.go
} func lock(l *mutex) { lockWithRank(l, getLockRank(l)) } func lock2(l *mutex) { if l.key == mutex_locked { // js/wasm is single-threaded so we should never // observe this. throw("self deadlock") } gp := getg() if gp.m.locks < 0 { throw("lock count") } gp.m.locks++ l.key = mutex_locked } func unlock(l *mutex) { unlockWithRank(l) } func unlock2(l *mutex) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 21 21:02:20 UTC 2023 - 7.3K bytes - Viewed (0) -
src/crypto/tls/conn_test.go
tlsConn := Server(conn, &Config{ GetCertificate: func(*ClientHelloInfo) (*Certificate, error) { panic("unreachable") }, }) conn.tlsConn = tlsConn // This call should not deadlock. tlsConn.Close() } func TestRecordBadVersionTLS13(t *testing.T) { client, server := localPipe(t) defer server.Close() defer client.Close() config := testConfig.Clone()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 24 21:35:01 UTC 2023 - 10.5K bytes - Viewed (0) -
src/runtime/mgc.go
lock(&sched.deferlock) // disconnect cached list before dropping it on the floor, // so that a dangling ref to one entry does not pin all of them. var d, dlink *_defer for d = sched.deferpool; d != nil; d = dlink { dlink = d.link d.link = nil } sched.deferpool = nil unlock(&sched.deferlock) } // Timing
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 16:25:21 UTC 2024 - 62K bytes - Viewed (0) -
src/context/example_test.go
stopf := context.AfterFunc(ctx, func() { // We need to acquire cond.L here to be sure that the Broadcast // below won't occur before the call to Wait, which would result // in a missed signal (and deadlock). cond.L.Lock() defer cond.L.Unlock() // If multiple goroutines are waiting on cond simultaneously, // we need to make sure we wake up exactly this one.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Aug 21 20:24:28 UTC 2023 - 6.7K bytes - Viewed (0)