- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 271 for defBlock (0.1 sec)
-
src/runtime/race/testdata/atomic_test.go
c := make(chan bool) var a uint64 go func() { atomic.AddUint64(&a, 1) c <- true }() a = 42 <-c } // A nil pointer in an atomic operation should not deadlock // the rest of the program. Used to hang indefinitely. func TestNoRaceAtomicCrash(t *testing.T) { var mutex sync.Mutex var nilptr *int32 panics := 0 defer func() { if x := recover(); x != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Nov 16 17:26:46 UTC 2020 - 4.9K 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/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/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) -
tensorflow/c/eager/parallel_device/parallel_device_lib.cc
const int in_flight_nodes_limit) : status_(TF_NewStatus()), // If the context's default exector is set to async, re-using that in // each thread would cause collectives to deadlock. For consistency we // create a new sync executor for every thread. // // TODO(allenl): We should have an async API that works with the // parallel device. device_(device),
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Feb 09 07:47:20 UTC 2024 - 25.4K bytes - Viewed (0)