- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 194 for sweeping (0.11 sec)
-
src/slices/iter.go
func SortedFunc[E any](seq iter.Seq[E], cmp func(E, E) int) []E { s := Collect(seq) SortFunc(s, cmp) return s } // SortedStableFunc collects values from seq into a new slice. // It then sorts the slice while keeping the original order of equal elements, // using the comparison function to compare elements. // It returns the new slice. func SortedStableFunc[E any](seq iter.Seq[E], cmp func(E, E) int) []E { s := Collect(seq)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 13 21:40:32 UTC 2024 - 2.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
} if (queue.futureTasks.isNotEmpty()) { readyQueues.add(queue) } } /** * Returns an immediately-executable task for the calling thread to execute, sleeping as necessary * until one is ready. If there are no ready queues, or if other threads have everything under * control this will return null. If there is more than a single task ready to execute immediately
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 29 00:33:04 UTC 2024 - 10.6K bytes - Viewed (0) -
src/net/net_windows_test.go
} return nil } if envaddr := os.Getenv("GOTEST_DIAL_ADDR"); envaddr != "" { // In child process. c, err := Dial("tcp", envaddr) if err != nil { t.Fatal(err) } fmt.Printf("sleeping\n") time.Sleep(time.Minute) // process will be killed here c.Close() } ln, err := Listen("tcp", "127.0.0.1:0") if err != nil { t.Fatal(err) } defer ln.Close()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 16.3K bytes - Viewed (0) -
build/common.sh
if [[ "${tag}" != "${2}"* ]] ; then V=3 kube::log::status "Keeping image ${1}:${tag}" continue fi if [[ -z "${3:-}" || "${tag}" != "${3}" ]] ; then V=2 kube::log::status "Deleting image ${1}:${tag}" "${DOCKER[@]}" rmi "${1}:${tag}" >/dev/null else V=3 kube::log::status "Keeping image ${1}:${tag}" fi done }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 16:13:15 UTC 2024 - 26.5K bytes - Viewed (0) -
src/runtime/select.go
typedmemmove(c.elemtype, chanbuf(c, c.sendx), cas.elem) c.sendx++ if c.sendx == c.dataqsiz { c.sendx = 0 } c.qcount++ selunlock(scases, lockorder) goto retc recv: // can receive from sleeping sender (sg) recv(c, sg, cas.elem, func() { selunlock(scases, lockorder) }, 2) if debugSelect { print("syncrecv: cas0=", cas0, " c=", c, "\n") } recvOK = true goto retc rclose:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 13 21:36:04 UTC 2024 - 15K bytes - Viewed (0) -
pkg/kubelet/cm/dra/state/state_checkpoint.go
CDIDevices map[string][]string } type stateCheckpoint struct { sync.RWMutex checkpointManager checkpointmanager.CheckpointManager checkpointName string } // NewCheckpointState creates new State for keeping track of claim info with checkpoint backend func NewCheckpointState(stateDir, checkpointName string) (*stateCheckpoint, error) { if len(checkpointName) == 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 03 13:23:27 UTC 2024 - 4.3K bytes - Viewed (0) -
platforms/core-runtime/time/src/main/java/org/gradle/internal/time/MonotonicClock.java
import java.util.concurrent.atomic.AtomicLong; /** * A clock that is guaranteed to not go backwards. * <p> * It aims to strike a balance between never going backwards (allowing timestamps to represent causality) * and keeping in sync with the system wall clock so that time values make sense in comparison with the system wall clock, * including timestamps generated from other processes. * <p>
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 20:20:17 UTC 2024 - 5K bytes - Viewed (0) -
src/runtime/mgcscavenge.go
printControllerReset bool // targetCPUFraction is the target CPU overhead for the scavenger. targetCPUFraction float64 // sleepRatio is the ratio of time spent doing scavenging work to // time spent sleeping. This is used to decide how long the scavenger // should sleep for in between batches of work. It is set by // critSleepController in order to maintain a CPU overhead of // targetCPUFraction. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:48:45 UTC 2024 - 52.3K bytes - Viewed (0) -
platforms/core-runtime/instrumentation-agent-services/src/integTest/groovy/org/gradle/internal/instrumentation/agent/AgentApplicationTest.groovy
then: agentWasApplied() } @Requires( value = IntegTestPreconditions.IsConfigCached, reason = "Tests the configuration cache behavior" ) def "keeping agent status does not invalidate the configuration cache"() { def configurationCache = new ConfigurationCacheFixture(this) given: withDumpAgentStatusAtConfiguration() when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 7.8K bytes - Viewed (0) -
src/runtime/trace.go
racerelease(unsafe.Pointer(&s.lock)) } unlock(&s.lock) } // close wakes any goroutine sleeping on the timer and prevents // further sleeping on it. // // Once close is called, the wakeableSleep must no longer be used. // // It must only be called once no goroutine is sleeping on the // timer *and* nothing else will call wake concurrently. func (s *wakeableSleep) close() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:17:41 UTC 2024 - 37.1K bytes - Viewed (0)