- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 1,040 for ONCE (0.14 sec)
-
platforms/core-runtime/service-provider/src/main/java/org/gradle/internal/service/scopes/GradleModuleServices.java
*/ @ServiceScope(Scope.Global.class) public interface GradleModuleServices extends ServiceRegistrationProvider { /** * Called once per process, to register any globally scoped services. These services are reused across builds in the same process. * The services are closed when the process finishes. *
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 27 12:34:44 UTC 2024 - 5.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_context.go
Wait() } type initializationSignal struct { once sync.Once done chan struct{} } func NewInitializationSignal() InitializationSignal { return &initializationSignal{ once: sync.Once{}, done: make(chan struct{}), } } func (i *initializationSignal) Signal() { i.once.Do(func() { close(i.done) }) } func (i *initializationSignal) Wait() { <-i.done
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 14 14:39:15 UTC 2021 - 2.9K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/strategicpatch/testing/openapi.go
// parse only once and then return the same copy everytime. type Fake struct { Path string once sync.Once document *openapi_v2.Document err error } // OpenAPISchema returns the openapi document and a potential error. func (f *Fake) OpenAPISchema() (*openapi_v2.Document, error) { f.once.Do(func() { _, err := os.Stat(f.Path) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 02 14:34:26 UTC 2023 - 1.7K bytes - Viewed (0) -
src/io/pipe.go
if err == nil { err = ErrClosedPipe } p.rerr.Store(err) p.once.Do(func() { close(p.done) }) return nil } func (p *pipe) write(b []byte) (n int, err error) { select { case <-p.done: return 0, p.writeCloseError() default: p.wrMu.Lock() defer p.wrMu.Unlock() } for once := true; once || len(b) > 0; once = false { select { case p.wrCh <- b: nw := <-p.rdCh b = b[nw:]
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Oct 18 19:34:35 UTC 2023 - 5.1K bytes - Viewed (0) -
src/crypto/x509/root.go
// // Do not remove or change the type signature. // 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() {
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/go/internal/vcweb/fossil.go
import ( "fmt" "log" "net/http" "net/http/cgi" "os" "os/exec" "path/filepath" "sync" ) type fossilHandler struct { once sync.Once fossilPath string fossilPathErr error } func (h *fossilHandler) Available() bool { h.once.Do(func() { h.fossilPath, h.fossilPathErr = exec.LookPath("fossil") }) return h.fossilPathErr == nil }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 21 17:47:26 UTC 2023 - 1.3K bytes - Viewed (0) -
src/mime/type_test.go
package mime import ( "reflect" "strings" "sync" "testing" ) func setMimeInit(fn func()) (cleanup func()) { once = sync.Once{} testInitMime = fn return func() { testInitMime = nil once = sync.Once{} } } func clearMimeTypes() { setMimeTypes(map[string]string{}, map[string]string{}) } func setType(ext, typ string) { if !strings.HasPrefix(ext, ".") {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Aug 08 21:09:03 UTC 2022 - 4.9K bytes - Viewed (0) -
src/net/pipe.go
case isClosedChan(p.writeDeadline.wait()): return 0, os.ErrDeadlineExceeded } p.wrMu.Lock() // Ensure entirety of b is written together defer p.wrMu.Unlock() for once := true; once || len(b) > 0; once = false { select { case p.wrTx <- b: nw := <-p.wrRx b = b[nw:] n += nw case <-p.localDone: return n, io.ErrClosedPipe case <-p.remoteDone:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 5.4K bytes - Viewed (0) -
subprojects/composite-builds/src/integTest/groovy/org/gradle/integtests/composite/CompositeBuildMinimalConfigurationIntegrationTest.groovy
compositeSubstitute() } } } def "build with discovered substitutions that is not required for dependency substitution is configured only once"() { given: dependency "org.test:buildB:1.0" includeBuild buildB includeBuild buildC when: buildC.buildFile << """ println 'Configured buildC'
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Dec 01 20:36:42 UTC 2022 - 6.4K bytes - Viewed (0) -
src/sync/oncefunc_test.go
var ( onceFunc = sync.OnceFunc(func() {}) onceFuncOnce sync.Once ) func doOnceFunc() { onceFuncOnce.Do(func() {}) } func BenchmarkOnceFunc(b *testing.B) { b.Run("v=Once", func(b *testing.B) { b.ReportAllocs() for i := 0; i < b.N; i++ { // The baseline is direct use of sync.Once. doOnceFunc() } }) b.Run("v=Global", func(b *testing.B) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 21 17:31:33 UTC 2023 - 6.9K bytes - Viewed (0)