Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 487 for race (0.04 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top