- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 168 for withers (0.15 sec)
-
guava/src/com/google/common/util/concurrent/AbstractFuture.java
} return old; } } /** Performs a GAS operation on the {@link #waiters} field. */ @Override Waiter gasWaiters(AbstractFuture<?> future, Waiter update) { synchronized (future) { Waiter old = future.waiters; if (old != update) { future.waiters = update; } return old; } } @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Jun 07 22:25:23 UTC 2024 - 62.8K bytes - Viewed (1) -
src/internal/poll/fd_mutex.go
// 1 bit - lock for read operations. // 1 bit - lock for write operations. // 20 bits - total number of references (read+write+misc). // 20 bits - number of outstanding read waiters. // 20 bits - number of outstanding write waiters. const ( mutexClosed = 1 << 0 mutexRLock = 1 << 1 mutexWLock = 1 << 2 mutexRef = 1 << 3 mutexRefMask = (1<<20 - 1) << 3 mutexRWait = 1 << 23
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 20 16:55:30 UTC 2018 - 6.4K bytes - Viewed (0) -
staging/src/k8s.io/client-go/applyconfigurations/admissionregistration/v1beta1/webhookclientconfig.go
return &WebhookClientConfigApplyConfiguration{} } // WithURL sets the URL field in the declarative configuration to the given value // and returns the receiver, so that objects can be built by chaining "With" function invocations. // If called multiple times, the URL field is set to the value of the last call. func (b *WebhookClientConfigApplyConfiguration) WithURL(value string) *WebhookClientConfigApplyConfiguration { b.URL = &value
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 04 18:31:34 UTC 2021 - 2.6K bytes - Viewed (0) -
src/sync/cond_test.go
benchmarkCond(b, 32) } func benchmarkCond(b *testing.B, waiters int) { c := NewCond(&Mutex{}) done := make(chan bool) id := 0 for routine := 0; routine < waiters+1; routine++ { go func() { for i := 0; i < b.N; i++ { c.L.Lock() if id == -1 { c.L.Unlock() break } id++ if id == waiters+1 { id = 0 c.Broadcast() } else {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 22 18:52:42 UTC 2023 - 5K bytes - Viewed (0) -
platforms/software/dependency-management/src/testFixtures/groovy/org/gradle/containers/GradleInContainer.groovy
started = false container.stop() monitor.interrupt() } } GradleInContainer withEnv(Map<String, ?> stringMap) { Map<String, String> env = [:] stringMap.each { k, v -> env[k] = v?.toString() } container.withEnv(env) this } ExecutionResult succeeds(String... tasks) { executer.withTasks(tasks) executer.run()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 10 21:10:11 UTC 2023 - 4.3K bytes - Viewed (0) -
.idea/dictionaries/valentin.xml
<w>rbrace</w> <w>rbracket</w> <w>renderers</w> <w>rparenth</w> <w>selectioner</w> <w>smartcast</w> <w>summand</w> <w>unpluralize</w> <w>weighers</w> </words> </dictionary>
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Tue Sep 13 14:46:16 UTC 2016 - 605 bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cache_watcher_test.go
} clock := testingclock.NewFakeClock(time.Now()) watchers := newTimeBucketWatchers(clock, defaultBookmarkFrequency) now := clock.Now() watchers.addWatcherThreadUnsafe(newWatcher(now.Add(10 * time.Second))) watchers.addWatcherThreadUnsafe(newWatcher(now.Add(20 * time.Second))) watchers.addWatcherThreadUnsafe(newWatcher(now.Add(20 * time.Second))) if len(watchers.watchersBuckets) != 2 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 09:20:10 UTC 2024 - 22.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/request/mutating_work_estimator.go
} } watchCount := e.countFn(requestInfo) metrics.ObserveWatchCount(r.Context(), priorityLevelName, flowSchemaName, watchCount) // The cost of the request associated with the watchers of that event // consists of three parts: // - cost of going through the event change logic // - cost of serialization of the event // - cost of processing an event object for each watcher (e.g. filtering,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 17 19:26:52 UTC 2023 - 6K bytes - Viewed (0) -
src/internal/zstd/testdata/1890a371.gettysburg.txt-100x.zst
1890a371.gettysburg.txt-100x.zst Four score and seven years ago our fathers brought forth on this continent, a new nation, conceived in Liberty, and dedicated to the proposition that all men are created equal. Now we are engaged in a great Civil War, testing whether that nation, or any nation so conceived and so dedicated, can long endure. We are met on a great battle-field of that war. We have come to dedicate a portion of that field, as a final resting place for those who here gave their lives...
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Sep 27 14:35:13 UTC 2023 - 826 bytes - Viewed (0) -
cmd/peer-s3-client.go
} } // HealBucket - heals buckets at node level func (sys *S3PeerSys) HealBucket(ctx context.Context, bucket string, opts madmin.HealOpts) (madmin.HealResultItem, error) { g := errgroup.WithNErrs(len(sys.peerClients)) for idx, client := range sys.peerClients { idx := idx client := client g.Go(func() error { if client == nil { return errPeerOffline }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 15.3K bytes - Viewed (0)