- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 1,525 for ONCE (0.2 sec)
-
src/cmd/go/internal/cache/default.go
"internal/goexperiment" ) // Default returns the default cache to use. // It never returns nil. func Default() Cache { defaultOnce.Do(initDefaultCache) return defaultCache } var ( defaultOnce sync.Once defaultCache Cache ) // cacheREADME is a message stored in a README in the cache directory. // Because the cache lives outside the normal Go trees, we leave the // README as a courtesy to explain where it came from.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 14:34:32 UTC 2024 - 3K bytes - Viewed (0) -
src/cmd/go/internal/par/work.go
// Package par implements parallel execution helpers. 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
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 13 15:54:54 UTC 2024 - 4.3K bytes - Viewed (0) -
platforms/core-configuration/file-collections/src/integTest/groovy/org/gradle/api/file/FileCollectionIntegrationTest.groovy
""" file("in.txt").text = "in" when: run("merge") then: output.count("calculating value") == 2 // once for task dependency calculation, once for task execution } def "task @InputFiles file collection provider is called once only when task executes"() { taskTypeWithInputFileCollection() buildFile """ task merge(type: InputFilesTask) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 12:54:09 UTC 2024 - 21K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/caching/internal/controller/impl/LifecycleAwareBuildCacheControllerFactory.java
* * <ul> * <li>All builds in the tree use the root build's cache configuration, once that configuration is available (ie the root build's settings have been evaluated).</li> * <li>If caching is required in non-root build before the root build's configuration is available, that build's own cache configuration will be used. * Once the root build's configuration is available, the build-specific configuration is discarded. * </li>
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Apr 22 23:28:13 UTC 2024 - 9.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/RealInterceptorChain.kt
"network interceptor ${interceptors[index - 1]} must retain the same host and port" } check(calls == 1) { "network interceptor ${interceptors[index - 1]} must call proceed() exactly once" } } // Call the next interceptor in the chain. val next = copy(index = index + 1, request = request) val interceptor = interceptors[index] @Suppress("USELESS_ELVIS")
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 4.2K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
* * - after the requireNonNull call below. (And this object has its Runnable.run override * called only once, just as it has its Executor.execute override called only once.) * * - if we return immediately from `execute` (in which case we never get here) *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 22.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
* * - after the requireNonNull call below. (And this object has its Runnable.run override * called only once, just as it has its Executor.execute override called only once.) * * - if we return immediately from `execute` (in which case we never get here) *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 22.1K bytes - Viewed (0) -
src/net/http/filetransport.go
// We start ServeHTTP in a goroutine, which may take a long // time if the file is large. The newPopulateResponseWriter // call returns a channel which either ServeHTTP or finish() // sends our *Response on, once the *Response itself has been // populated (even if the body itself is still being // written to the res.Body, a pipe) rw, resc := newPopulateResponseWriter() go func() { t.fh.ServeHTTP(rw, req) rw.finish()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 3.5K bytes - Viewed (0) -
analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/scopes/DeclarationsInPackageProvider.kt
val generatedTopLevelClassifiers = declarationGenerators .asSequence() .flatMap { // FIXME this function should be called only once during plugin's lifetime, so this usage is not really correct (2) it.getTopLevelClassIds() } .filter { it.packageFqName == packageFqName } .map { it.shortClassName }
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Thu Jun 06 17:44:50 UTC 2024 - 5.3K bytes - Viewed (0) -
cmd/service.go
return syscall.Exec(argv0, os.Args, os.Environ()) } // freezeServices will freeze all incoming S3 API calls. // For each call, unfreezeServices must be called once. func freezeServices() { // Use atomics for globalServiceFreeze, so we can read without locking. // We need a lock since we are need the 2 atomic values to remain in sync. globalServiceFreezeMu.Lock()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Feb 28 07:02:14 UTC 2024 - 3.8K bytes - Viewed (0)