- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 487 for race (0.04 sec)
-
guava/src/com/google/common/util/concurrent/CollectionFuture.java
* on the fields of TimeoutFuture. This field is slightly different from the fields discussed * there: cancel() never reads this field, only writes to it. That makes the race here completely * harmless, rather than just 99.99% harmless. */ @CheckForNull @LazyInit private List<@Nullable Present<V>> values; CollectionFuture(
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 3.8K bytes - Viewed (0) -
src/sync/pool_test.go
// Copyright 2013 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. // Pool is no-op under race detector, so all these tests do not work. // //go:build !race package sync_test import ( "runtime" "runtime/debug" "slices" . "sync" "sync/atomic" "testing" "time" ) func TestPool(t *testing.T) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/CollectionFuture.java
* on the fields of TimeoutFuture. This field is slightly different from the fields discussed * there: cancel() never reads this field, only writes to it. That makes the race here completely * harmless, rather than just 99.99% harmless. */ @CheckForNull @LazyInit private List<@Nullable Present<V>> values; CollectionFuture(
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 3.8K bytes - Viewed (0) -
src/os/read_test.go
} func TestWriteFile(t *testing.T) { t.Parallel() f, err := CreateTemp("", "os-test") if err != nil { t.Fatal(err) } defer f.Close() defer Remove(f.Name()) msg := "Programming today is a race between software engineers striving to " + "build bigger and better idiot-proof programs, and the Universe trying " + "to produce bigger and better idiots. So far, the Universe is winning."
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 10 02:36:46 UTC 2024 - 3.2K bytes - Viewed (0) -
src/os/signal/signal.go
if h.want(n) { handlers.ref[n]-- if handlers.ref[n] == 0 { disableSignal(n) } } } // Signals will no longer be delivered to the channel. // We want to avoid a race for a signal such as SIGINT: // it should be either delivered to the channel, // or the program should take the default action (that is, exit). // To avoid the possibility that the signal is delivered,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 26 21:33:12 UTC 2024 - 8.3K bytes - Viewed (0) -
src/os/dir_darwin.go
if errno != nil { return nil, nil, nil, &PathError{Op: call, Path: f.name, Err: errno} } d = &dirInfo{dir: dir} if f.dirinfo.CompareAndSwap(nil, d) { break } // We lost the race: try again. d.close() } size := n if size <= 0 { size = 100 n = -1 } var dirent syscall.Dirent var entptr *syscall.Dirent for len(names)+len(dirents)+len(infos) < size || n == -1 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 20:52:06 UTC 2024 - 3.5K bytes - Viewed (0) -
src/syscall/exec_unix.go
// have to allocate the descriptor and then mark it close-on-exec. // If a fork happens between those two events, the child's exec // will inherit an unwanted file descriptor. // // This lock solves that race: the create new fd/mark close-on-exec // operation is done holding ForkLock for reading, and the fork itself // is done holding ForkLock for writing. At least, that's the idea. // There are some complications. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 26 21:03:59 UTC 2024 - 8.7K bytes - Viewed (0) -
src/runtime/malloc.go
// simpler code to avoid floating point. func nextSampleNoFP() uintptr { // Set first allocation sample size. rate := MemProfileRate if rate > 0x3fffffff { // make 2*rate not overflow rate = 0x3fffffff } if rate != 0 { return uintptr(cheaprandn(uint32(2 * rate))) } return 0 } type persistentAlloc struct { base *notInHeap off uintptr }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 59.6K bytes - Viewed (0) -
security/pkg/credentialfetcher/plugin/gce.go
jwtPath string // identity provider identityProvider string // token refresh rotationTicker *time.Ticker closing chan bool tokenCache string // mutex lock is required to avoid race condition when updating token file and token cache. tokenMutex sync.RWMutex } // CreateGCEPlugin creates a Google credential fetcher plugin. Return the pointer to the created plugin.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 13:56:46 UTC 2024 - 4.7K bytes - Viewed (0) -
pilot/pkg/model/endpointshards.go
// condition is introduced where an XDS response may be generated before the update, but not // completed until after a response after the update. Essentially, we transition from v0 -> v1 -> // v0 -> invalidate -> v1. Reverting a change we pushed violates our contract of monotonically // moving forward in version. In practice, this is pretty rare and self corrects nearly
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 15.6K bytes - Viewed (0)