- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 255 for Sleeping (0.33 sec)
-
src/runtime/sigqueue_plan9.go
// by the os/signal package. // //go:linkname signalWaitUntilIdle os/signal.signalWaitUntilIdle func signalWaitUntilIdle() { for { lock(&sig.lock) sleeping := sig.sleeping unlock(&sig.lock) if sleeping { return } Gosched() } } // Must only be called from a single goroutine at a time. // //go:linkname signal_enable os/signal.signal_enable
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 05 17:54:15 UTC 2022 - 3.3K bytes - Viewed (0) -
src/runtime/lock_futex.go
// If any procs are sleeping on addr, wake up at most cnt. const ( mutex_unlocked = 0 mutex_locked = 1 mutex_sleeping = 2 active_spin = 4 active_spin_cnt = 30 passive_spin = 1 ) // Possible lock states are mutex_unlocked, mutex_locked and mutex_sleeping. // mutex_sleeping means that there is presumably at least one sleeping thread.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:34 UTC 2024 - 5.4K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/daemon/LegacyDaemon.groovy
logFileProbe = new DaemonLogFileStateProbe(daemonLog, context) } else { logFileProbe = new DaemonLogFileStateProbe(daemonLog, context, "Daemon is busy, sleeping until state changes", "Daemon is idle, sleeping until state change") } } protected void waitForState(State state) { def timer = Time.startCountdownTimer(STATE_CHANGE_TIMEOUT)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 15:22:16 UTC 2024 - 2.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java
} catch (InterruptedException e) { // ok. just stop sleeping. } if (shouldStop) { break; } interruptee.interrupt(); } } void stopInterrupting() { shouldStop = true; } } /** Interrupts the current thread after sleeping for the specified delay. */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 4.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java
} catch (InterruptedException e) { // ok. just stop sleeping. } if (shouldStop) { break; } interruptee.interrupt(); } } void stopInterrupting() { shouldStop = true; } } /** Interrupts the current thread after sleeping for the specified delay. */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 4.4K bytes - Viewed (0) -
cluster/gce/gci/shutdown.sh
preemptible=$(curl "http://metadata.google.internal/computeMetadata/v1/instance/scheduling/preemptible" -H "Metadata-Flavor: Google") if [ "${preemptible}" == "TRUE" ]; then echo "Shutting down! Sleeping for a minute to let the node gracefully terminate" # https://cloud.google.com/compute/docs/instances/stopping-or-deleting-an-instance#delete_timeout sleep 30
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 03:46:45 UTC 2019 - 1.1K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DaemonStateCoordinator.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:38 UTC 2024 - 17.1K bytes - Viewed (0) -
buildscripts/minio-upgrade.sh
add_alias() { for i in $(seq 1 4); do echo "... attempting to add alias $i" until (mc alias set minio http://127.0.0.1:9000 minioadmin minioadmin); do echo "...waiting... for 5secs" && sleep 5 done done echo "Sleeping for nginx" sleep 20 } __init__() { sudo apt install curl -y export GOPATH=/tmp/gopath export PATH=${PATH}:${GOPATH}/bin go install github.com/minio/mc@latest
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 05:08:11 UTC 2024 - 2.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerRealBackendTest.kt
import org.junit.jupiter.api.Test /** * Integration test to confirm that [TaskRunner] works with a real backend. Business logic is all * exercised by [TaskRunnerTest]. * * This test is doing real sleeping with tolerances of 250 ms. Hopefully that's enough for even the * busiest of CI servers. */ @Tag("Slowish") class TaskRunnerRealBackendTest { private val log = LinkedBlockingDeque<String>()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3.5K bytes - Viewed (0) -
src/runtime/lock_sema.go
// If ns >= 0, try to acquire m's semaphore for at most ns nanoseconds. // Return 0 if the semaphore was acquired, -1 if interrupted or timed out. // // func semawakeup(mp *m) // Wake up mp, which is or will soon be sleeping on its semaphore. const ( locked uintptr = 1 active_spin = 4 active_spin_cnt = 30 passive_spin = 1 ) func mutexContended(l *mutex) bool { return atomic.Loaduintptr(&l.key) > locked }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:37 UTC 2024 - 6.8K bytes - Viewed (0)