- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 662 for goroutines (0.19 sec)
-
src/os/tempfile.go
// The file is created with mode 0o600 (before umask). // If dir is the empty string, CreateTemp uses the default directory for temporary files, as returned by [TempDir]. // Multiple programs or goroutines calling CreateTemp simultaneously will not choose the same file. // The caller can use the file's Name method to find the pathname of the file. // It is the caller's responsibility to remove the file when it is no longer needed.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 12 18:04:39 UTC 2024 - 3.9K bytes - Viewed (0) -
src/runtime/rwmutex_test.go
<-clocked } cunlock.Store(true) // Wait for the goroutines to finish. for i := 0; i < numReaders; i++ { <-cdone } } func TestParallelRWMutexReaders(t *testing.T) { if GOARCH == "wasm" { t.Skip("wasm has no threads yet") } defer GOMAXPROCS(GOMAXPROCS(-1)) // If runtime triggers a forced GC during this test then it will deadlock, // since the goroutines can't be stopped/preempted.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Dec 15 22:00:45 UTC 2023 - 4.2K bytes - Viewed (0) -
pilot/pkg/leaderelection/leak_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 28 04:22:19 UTC 2024 - 799 bytes - Viewed (0) -
doc/go_mem.html
Some, such as atomic compare-and-swap, are both read-like and write-like. </p> <p> A <i>goroutine execution</i> is modeled as a set of memory operations executed by a single goroutine. </p> <p> <b>Requirement 1</b>: The memory operations in each goroutine must correspond to a correct sequential execution of that goroutine, given the values read from and written to memory.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 04 15:54:42 UTC 2024 - 26.6K bytes - Viewed (0) -
src/runtime/netpoll.go
// pollDesc contains 2 binary semaphores, rg and wg, to park reader and writer // goroutines respectively. The semaphore can be in the following states: // // pdReady - io readiness notification is pending; // a goroutine consumes the notification by changing the state to pdNil. // pdWait - a goroutine prepares to park on the semaphore, but not yet parked; // the goroutine commits to park by changing the state to G pointer,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 19:57:43 UTC 2024 - 20.7K bytes - Viewed (0) -
src/runtime/proc.go
if debug.dontfreezetheworld > 0 { // Don't prempt Ps to stop goroutines. That will perturb // scheduler state, making debugging more difficult. Instead, // allow goroutines to continue execution. // // fatalpanic will tracebackothers to trace all goroutines. It // is unsafe to trace a running goroutine, so tracebackothers // will skip running goroutines. That is OK and expected, we
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/trace.go
// context where it could emit an event by bringing all goroutines to a safe point // with no opportunity to transition. // // The exception to this rule are goroutines that are concurrently exiting a syscall. // Those will all be forced into the syscalling slow path, and we'll just make sure // that we don't observe any goroutines in that critical section before starting
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:17:41 UTC 2024 - 37.1K bytes - Viewed (0) -
test/fixedbugs/issue21576.go
defer cancel() cmd := exec.CommandContext(ctx, "go", "run", file) output, err := cmd.CombinedOutput() if err == nil { log.Fatalf("Passed, expected an error") } want := []byte("fatal error: all goroutines are asleep - deadlock!") if !bytes.Contains(output, want) { log.Fatalf("Unmatched error message %q:\nin\n%s\nError: %v", want, output, err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:25 UTC 2023 - 1.3K bytes - Viewed (0) -
src/testing/benchmark_test.go
// RunParallel will create GOMAXPROCS goroutines // and distribute work among them. b.RunParallel(func(pb *testing.PB) { // Each goroutine has its own bytes.Buffer. var buf bytes.Buffer for pb.Next() { // The loop body is executed b.N times total across all goroutines. buf.Reset() templ.Execute(&buf, "World") } }) }) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 5.6K bytes - Viewed (0) -
src/runtime/preempt.go
// readying it when done. stopped bool } // suspendG suspends goroutine gp at a safe-point and returns the // state of the suspended goroutine. The caller gets read access to // the goroutine until it calls resumeG. // // It is safe for multiple callers to attempt to suspend the same // goroutine at the same time. The goroutine may execute between // subsequent successful suspend operations. The current
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 15:41:45 UTC 2024 - 15.1K bytes - Viewed (0)