- Sort Score
- Result 10 results
- Languages All
Results 191 - 200 of 1,199 for syncAt (0.08 sec)
-
src/sync/example_test.go
package sync_test import ( "fmt" "os" "sync" ) type httpPkg struct{} func (httpPkg) Get(url string) {} var http httpPkg // This example fetches several URLs concurrently, // using a WaitGroup to block until all the fetches are complete. func ExampleWaitGroup() { var wg sync.WaitGroup var urls = []string{ "http://www.golang.org/", "http://www.google.com/",
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 23 17:45:47 UTC 2024 - 2.2K bytes - Viewed (0) -
src/cmd/go/internal/imports/tags.go
// Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. package imports import ( "cmd/go/internal/cfg" "sync" ) var ( tags map[string]bool tagsOnce sync.Once ) // Tags returns a set of build tags that are true for the target platform. // It includes GOOS, GOARCH, the compiler, possibly "cgo",
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Aug 26 17:43:59 UTC 2022 - 1.3K bytes - Viewed (0) -
pkg/kubelet/volumemanager/populator/desired_state_of_world_populator.go
limitations under the License. */ /* Package populator implements interfaces that monitor and keep the states of the caches in sync with the "ground truth". */ package populator import ( "context" "errors" "fmt" "sync" "time" "k8s.io/klog/v2" v1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/types"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 23.8K bytes - Viewed (0) -
test/fixedbugs/issue33355.go
// This code failed on arm64 in the register allocator. // See issue 33355. package server import ( "bytes" "sync" ) type client struct { junk [4]int mu sync.Mutex srv *Server gw *gateway msgb [100]byte } type gateway struct { cfg *gatewayCfg outsim *sync.Map } type gatewayCfg struct { replyPfx []byte } type Account struct { Name string }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Aug 01 02:15:18 UTC 2019 - 2.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/kmsv2/cache_test.go
limitations under the License. */ // Package kmsv2 transforms values for storage at rest using a Envelope v2 provider package kmsv2 import ( "crypto/rand" "crypto/sha256" "fmt" "sync" "sync/atomic" "testing" "time" "k8s.io/apimachinery/pkg/util/sets" "k8s.io/apiserver/pkg/storage/value" testingclock "k8s.io/utils/clock/testing" ) func TestSimpleCacheSetError(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 31 20:26:58 UTC 2023 - 4.9K bytes - Viewed (0) -
samples/jwt-server/src/main.go
log.Fatalf("Failed to start HTTPS server: %v", err) } } func (s *JWTServer) runHTTP(httpAddr string) { var wg sync.WaitGroup wg.Add(1) go s.startHTTP(httpAddr, &wg) wg.Wait() } func (s *JWTServer) runHTTPS(httpsAddr string) { var wg sync.WaitGroup wg.Add(1) go s.startHTTPS(httpsAddr, &wg) wg.Wait() } func (s *JWTServer) stop() { s.httpServer.Close() }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 16 23:56:50 UTC 2024 - 4.4K bytes - Viewed (0) -
src/syscall/forkpipe2.go
//go:build dragonfly || freebsd || linux || netbsd || openbsd || solaris package syscall import "sync" // forkExecPipe atomically opens a pipe with O_CLOEXEC set on both file // descriptors. func forkExecPipe(p []int) error { return Pipe2(p, O_CLOEXEC) } var ( // Guard the forking variable. forkingLock sync.Mutex // Number of goroutines currently forking, and thus the
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jul 10 19:19:59 UTC 2023 - 2.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/metrics/metrics.go
StabilityLevel: metrics.ALPHA, }, []string{"status", "apiserver_id_hash"}, ) ) var registerMetrics sync.Once var hashPool *sync.Pool func RegisterMetrics() { registerMetrics.Do(func() { hashPool = &sync.Pool{ New: func() interface{} { return sha256.New() }, } legacyregistry.MustRegister(encryptionConfigAutomaticReloadsTotal)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 13 05:47:46 UTC 2024 - 4.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/cmd/cgo/internal/testsanitizers/testdata/tsan6.go
/* #cgo CFLAGS: -fsanitize=thread #cgo LDFLAGS: -fsanitize=thread void f(char *p) { *p = 1; } */ import "C" import ( "runtime" "sync" ) func main() { var wg sync.WaitGroup var mu sync.Mutex c := make(chan []C.char, 100) for i := 0; i < 10; i++ { wg.Add(2) go func() { defer wg.Done() for i := 0; i < 100; i++ { c <- make([]C.char, 4096)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 12 11:59:56 UTC 2023 - 817 bytes - Viewed (0)