Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 111 for wakep (0.35 sec)

  1. guava/src/com/google/common/util/concurrent/InterruptibleTask.java

              //                ||----w |
              //                ||     ||
              // We need to clear the interrupted bit prior to calling park and maintain it in case we
              // wake up spuriously.
              restoreInterruptedBit = Thread.interrupted() || restoreInterruptedBit;
              LockSupport.park(blocker);
            }
          } else {
            Thread.yield();
          }
          state = get();
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Sep 29 21:34:48 UTC 2023
    - 9.9K bytes
    - Viewed (0)
  2. src/os/exec/exec_posix_test.go

    	// or an equivalent error.)
    	if err := cmd.Process.Signal(syscall.SIGCONT); err != nil {
    		t.Error(err)
    		syscall.Kill(cmd.Process.Pid, syscall.SIGCONT)
    	}
    
    	// The SIGCONT should allow the process to wake up, notice that stdin
    	// is closed, and exit successfully.
    	stdin.Close()
    	err = <-ch
    	if err != nil {
    		t.Fatal(err)
    	}
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Oct 13 20:21:32 UTC 2022
    - 6.8K bytes
    - Viewed (0)
  3. pkg/cache/ttlCache.go

    			w.stopEvicter <- true
    			w.evicterTerminated.Wait()
    		})
    		return result
    	}
    
    	return c
    }
    
    func (c *ttlCache) evicter(evictionInterval time.Duration) {
    	// Wake up once in a while and evict stale items
    	ticker := time.NewTicker(evictionInterval)
    	for {
    		select {
    		case now := <-ticker.C:
    			c.evictExpired(now)
    		case <-c.stopEvicter:
    			ticker.Stop()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 23 17:08:31 UTC 2023
    - 7.8K bytes
    - Viewed (0)
  4. lib/time/zoneinfo.zip

    Pacific/Norfolk Pacific/Noumea Pacific/Pago_Pago Pacific/Palau Pacific/Pitcairn Pacific/Pohnpei Pacific/Ponape Pacific/Port_Moresby Pacific/Rarotonga Pacific/Saipan Pacific/Samoa Pacific/Tahiti Pacific/Tarawa Pacific/Tongatapu Pacific/Truk Pacific/Wake Pacific/Wallis Pacific/Yap Poland Portugal ROC ROK Singapore Turkey UCT US/Alaska US/Aleutian US/Arizona US/Central US/East-Indiana US/Eastern US/Hawaii US/Indiana-Starke US/Michigan US/Mountain US/Pacific US/Samoa UTC Universal W-SU WET Zulu...
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Feb 02 18:20:41 UTC 2024
    - 392.3K bytes
    - Viewed (1)
  5. src/runtime/chan.go

    	gp.param = nil
    	if mysg.releasetime > 0 {
    		blockevent(mysg.releasetime-t0, 2)
    	}
    	mysg.c = nil
    	releaseSudog(mysg)
    	if closed {
    		if c.closed == 0 {
    			throw("chansend: spurious wakeup")
    		}
    		panic(plainError("send on closed channel"))
    	}
    	return true
    }
    
    // send processes a send operation on an empty channel c.
    // The value ep sent by the sender is copied to the receiver sg.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:16:50 UTC 2024
    - 25.9K bytes
    - Viewed (0)
  6. pkg/volume/util/nestedpendingoperations/nestedpendingoperations.go

    	// the lock is acquired first when operationCompletes begins, and is
    	// released when the method finishes, after the lock is released cond is
    	// signaled to wake waiting goroutine.
    	defer grm.cond.Signal()
    	grm.lock.Lock()
    	defer grm.lock.Unlock()
    
    	if *err == nil || !grm.exponentialBackOffOnError {
    		// Operation completed without error, or exponentialBackOffOnError disabled
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Aug 26 01:29:17 UTC 2022
    - 12.6K bytes
    - Viewed (0)
  7. src/runtime/mgcsweep.go

    		c.fullUnswept(sg).reset()
    	}
    
    	// Sweeping is done, so there won't be any new memory to
    	// scavenge for a bit.
    	//
    	// If the scavenger isn't already awake, wake it up. There's
    	// definitely work for it to do at this point.
    	scavenger.wake()
    
    	nextMarkBitArenaEpoch()
    }
    
    func bgsweep(c chan int) {
    	sweep.g = getg()
    
    	lockInit(&sweep.lock, lockRankSweep)
    	lock(&sweep.lock)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 08 17:52:18 UTC 2024
    - 32.9K bytes
    - Viewed (0)
  8. src/os/signal/signal_cgo_test.go

    		if err := unix.Tcsetpgrp(ptyFD, pgrp); err != nil {
    			return fmt.Errorf("error setting tty process group: %w", err)
    		}
    
    		// Give the kernel time to potentially wake readers and have
    		// them return EINTR (darwin does this).
    		time.Sleep(pause)
    
    		// Give TTY back.
    		pid := int32(cmd.Process.Pid) // assume that pid_t is int32
    		if err := unix.Tcsetpgrp(ptyFD, pid); err != nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Mar 20 10:09:15 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/AbstractFuture.java

                    removeWaiter(node);
                    throw new InterruptedException();
                  }
    
                  // Otherwise re-read and check doneness. If we loop then it must have been a spurious
                  // wakeup
                  localValue = value;
                  if (localValue != null & !(localValue instanceof SetFuture)) {
                    return getDoneValue(localValue);
                  }
    
                  // timed out?
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 63.1K bytes
    - Viewed (1)
  10. guava/src/com/google/common/util/concurrent/AbstractFuture.java

                    removeWaiter(node);
                    throw new InterruptedException();
                  }
    
                  // Otherwise re-read and check doneness. If we loop then it must have been a spurious
                  // wakeup
                  localValue = value;
                  if (localValue != null & !(localValue instanceof SetFuture)) {
                    return getDoneValue(localValue);
                  }
    
                  // timed out?
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 62.8K bytes
    - Viewed (1)
Back to top