Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 56 for Synchronizer (0.19 sec)

  1. pkg/volume/util/atomic_writer.go

    // a target directory.
    //
    // Note:
    //
    //  1. AtomicWriter reserves the set of pathnames starting with `..`.
    //  2. AtomicWriter offers no concurrency guarantees and must be synchronized
    //     by the caller.
    //
    // The visible files in this volume are symlinks to files in the writer's data
    // directory.  Actual files are stored in a hidden timestamped directory which
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 12:32:15 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/helper/SystemHelper.java

            }
        }
    
        protected short getSystemCpuPercent() {
            final long now = getCurrentTimeAsLong();
            if (now - systemCpuCheckTime > systemCpuCheckInterval) {
                synchronized (this) {
                    if (now - systemCpuCheckTime > systemCpuCheckInterval) {
                        try {
                            final OsProbe osProbe = OsProbe.getInstance();
    Registered: Wed Jun 12 13:08:18 UTC 2024
    - Last Modified: Sun May 26 05:52:29 UTC 2024
    - 26.5K bytes
    - Viewed (0)
  3. src/cmd/vendor/golang.org/x/sys/unix/zerrors_linux_amd64.go

    	{40, "ELOOP", "too many levels of symbolic links"},
    	{42, "ENOMSG", "no message of desired type"},
    	{43, "EIDRM", "identifier removed"},
    	{44, "ECHRNG", "channel number out of range"},
    	{45, "EL2NSYNC", "level 2 not synchronized"},
    	{46, "EL3HLT", "level 3 halted"},
    	{47, "EL3RST", "level 3 reset"},
    	{48, "ELNRNG", "link number out of range"},
    	{49, "EUNATCH", "protocol driver not attached"},
    	{50, "ENOCSI", "no CSI structure available"},
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 04 16:19:04 UTC 2024
    - 34.2K bytes
    - Viewed (0)
  4. src/sync/map.go

    //
    // The zero Map is empty and ready for use. A Map must not be copied after first use.
    //
    // In the terminology of [the Go memory model], Map arranges that a write operation
    // “synchronizes before” any read operation that observes the effect of the write, where
    // read and write operations are defined as follows.
    // [Map.Load], [Map.LoadAndDelete], [Map.LoadOrStore], [Map.Swap], [Map.CompareAndSwap],
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  5. src/runtime/race_ppc64le.s

    	RET				//
    racecallatomic_ignore:
    	// Addr is outside the good range.
    	// Call __tsan_go_ignore_sync_begin to ignore synchronization during the atomic op.
    	// An attempt to synchronize on the address would cause crash.
    	MOVD	R8, R15	// save the original function
    	MOVD	R6, R17 // save the original arg list addr
    	MOVD	$__tsan_go_ignore_sync_begin(SB), R8 // func addr to call
    	MOVD    runtime·tls_g(SB), R10
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:37:29 UTC 2024
    - 17K bytes
    - Viewed (0)
  6. src/runtime/stack.go

    			// It's not safe for someone to shrink this stack while we're actively
    			// parking on a channel, but it is safe to grow since we do that
    			// ourselves and explicitly don't want to synchronize with channels
    			// since we could self-deadlock.
    			throw("racy sudog adjustment due to parking on channel")
    		}
    		adjustsudogs(gp, &adjinfo)
    	} else {
    		// sudogs may be pointing in to the stack and gp has
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 22:31:00 UTC 2024
    - 41.1K bytes
    - Viewed (0)
  7. src/go/token/position.go

    	return f.PositionFor(p, true)
    }
    
    // -----------------------------------------------------------------------------
    // FileSet
    
    // A FileSet represents a set of source files.
    // Methods of file sets are synchronized; multiple goroutines
    // may invoke them concurrently.
    //
    // The byte offsets for each file in a file set are mapped into
    // distinct (integer) intervals, one interval [base, base+size]
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 19.7K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/collect/ImmutableList.java

       * {@code ImmutableList.of(list)} returns an {@code ImmutableList<List<String>>} containing one
       * element (the given list itself).
       *
       * <p>This method is safe to use even when {@code elements} is a synchronized or concurrent
       * collection that is currently being modified by another thread.
       *
       * @throws NullPointerException if {@code elements} contains a null element
       */
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Sun Jun 02 13:36:19 UTC 2024
    - 27.1K bytes
    - Viewed (0)
  9. src/internal/trace/summary.go

    	return &Summary{
    		Goroutines: s.gs,
    		Tasks:      s.tasks,
    	}
    }
    
    // RelatedGoroutinesV2 finds a set of goroutines related to goroutine goid for v2 traces.
    // The association is based on whether they have synchronized with each other in the Go
    // scheduler (one has unblocked another).
    func RelatedGoroutinesV2(events []Event, goid GoID) map[GoID]struct{} {
    	// Process all the events, looking for transitions of goroutines
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 20.7K bytes
    - Viewed (0)
  10. src/syscall/syscall_linux_test.go

    	var wg sync.WaitGroup
    	ready := make(chan bool)
    	wg.Add(1)
    	go func() {
    		data := make([]byte, 1)
    
    		// To narrow the window we have to wait for this
    		// goroutine to block in read, synchronize just before
    		// calling read.
    		ready <- true
    
    		// We use syscall.Read directly to avoid the poller.
    		// This will return when the write side is closed.
    		n, err := syscall.Read(int(rd.Fd()), data)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 23K bytes
    - Viewed (0)
Back to top