- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 80 for syncAt (0.13 sec)
-
src/cmd/trace/testdata/testprog/main.go
package main import ( "fmt" "log" "net" "os" "runtime" "runtime/trace" "sync" "syscall" "time" ) func main() { if err := trace.Start(os.Stdout); err != nil { log.Fatal(err) } // checkExecutionTimes relies on this. var wg sync.WaitGroup wg.Add(2) go cpu10(&wg) go cpu20(&wg) wg.Wait() // checkHeapMetrics relies on this.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 17:15:58 UTC 2024 - 2.5K bytes - Viewed (0) -
src/cmd/go/internal/par/work.go
package par import ( "errors" "math/rand" "sync" "sync/atomic" ) // Work manages a set of work items to be executed in parallel, at most once each. // The items in the set must all be valid map keys. type Work[T comparable] struct { f func(T) // function to run for each item running int // total number of runners mu sync.Mutex added map[T]bool // items added to set
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 13 15:54:54 UTC 2024 - 4.3K bytes - Viewed (0) -
src/sync/waitgroup.go
// Copyright 2011 The Go Authors. All rights reserved. // Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. package sync import ( "internal/race" "sync/atomic" "unsafe" ) // A WaitGroup waits for a collection of goroutines to finish. // The main goroutine calls [WaitGroup.Add] to set the number of // goroutines to wait for. Then each of the goroutines
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 4K bytes - Viewed (0) -
src/crypto/rand/rand_plan9.go
// reader always returns the full amount asked for, or else it // returns an error. The generator is a fast key erasure RNG. type reader struct { mu sync.Mutex seeded sync.Once seedErr error key [32]byte } func (r *reader) Read(b []byte) (n int, err error) { r.seeded.Do(func() { t := time.AfterFunc(time.Minute, func() { println("crypto/rand: blocked for 60 seconds waiting to read random data from the kernel")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 13 18:57:38 UTC 2024 - 1.8K bytes - Viewed (0) -
src/unique/handle.go
// over the sync.Map and call functions on the type-specific data structures otherwise. // These cleanup funcs each close over one of these type-specific maps. // // cleanupMu protects cleanupNotify and is held across the entire cleanup. Used for testing. // cleanupNotify is a test-only mechanism that allow tests to wait for the cleanup to run. cleanupMu sync.Mutex cleanupFuncsMu sync.Mutex
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 16:01:55 UTC 2024 - 5.3K bytes - Viewed (0) -
internal/event/targetlist.go
func (list *TargetList) Send(event Event, targetIDset TargetIDSet, sync bool) { if sync { list.sendSync(event, targetIDset) } else { list.sendAsync(event, targetIDset) } } func (list *TargetList) sendSync(event Event, targetIDset TargetIDSet) { var wg sync.WaitGroup for id := range targetIDset { target, ok := list.get(id) if !ok { continue }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 9.2K bytes - Viewed (0) -
src/crypto/x509/root.go
// See go.dev/issue/67401. // //go:linkname systemRoots var ( once sync.Once systemRootsMu sync.RWMutex systemRoots *CertPool systemRootsErr error fallbacksSet bool ) func systemRootsPool() *CertPool { once.Do(initSystemRoots) systemRootsMu.RLock() defer systemRootsMu.RUnlock() return systemRoots } func initSystemRoots() { systemRootsMu.Lock()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 2.3K bytes - Viewed (0) -
src/cmd/internal/objabi/pkgspecial.go
"-internal/bytealg", } var noRaceFuncPkgs = []string{"sync", "sync/atomic", "internal/runtime/atomic"} var allowAsmABIPkgs = []string{ "runtime", "reflect", "syscall", "internal/bytealg", "internal/chacha8rand", "internal/runtime/syscall", "runtime/internal/startlinetest", } var ( pkgSpecials map[string]PkgSpecial pkgSpecialsOnce sync.Once )
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 02:32:19 UTC 2024 - 3.8K bytes - Viewed (0) -
src/internal/testlog/exit.go
// Copyright 2020 The Go Authors. All rights reserved. // Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. package testlog import ( "sync" _ "unsafe" // for linkname ) // PanicOnExit0 reports whether to panic on a call to os.Exit(0). // This is in the testlog package because, like other definitions in // package testlog, it is a hook between the testing package and the
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 1.3K bytes - Viewed (0) -
internal/cachevalue/cache.go
// // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package cachevalue import ( "context" "sync" "sync/atomic" "time" ) // Opts contains options for the cache. type Opts struct { // When set to true, return the last cached value // even if updating the value errors out.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 12:50:46 UTC 2024 - 4.4K bytes - Viewed (0)