- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 255 for Sleeping (0.16 sec)
-
tensorflow/compiler/mlir/tfrt/tests/tfrt_fallback/batching_fallback.mlir
func.func @matmul_cpu(%ch: !tfrt.chain, %a: !tfrt_fallback.tf_tensor, %b: !tfrt_fallback.tf_tensor) -> (!tfrt.chain, !tfrt_fallback.tf_tensor) { // Enqueue a sleep onto blocking work queue, %ch0 is fulfilled when sleeping is done. %us = tfrt.constant.i32 1000 %ch0 = "tfrt_test.blocking.usleep"(%us) : (i32) -> (!tfrt.chain) %ch1 = tfrt.merge.chains %ch, %ch0 : !tfrt.chain, !tfrt.chain
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Jul 18 22:58:56 UTC 2023 - 8.6K 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) -
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) -
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) -
.github/actions/notify-translations/app/main.py
github_event = PartialGitHubEvent.parse_raw(contents) # Avoid race conditions with multiple labels sleep_time = random.random() * 10 # random number between 0 and 10 seconds logging.info( f"Sleeping for {sleep_time} seconds to avoid " "race conditions and multiple comments" ) time.sleep(sleep_time) # Get PR logging.debug(f"Processing PR: #{github_event.pull_request.number}")
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Wed Sep 27 23:01:46 UTC 2023 - 12.4K 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) -
android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
assertFalse("Capable of acquiring an additional permit", r.tryAcquire()); stopwatch.sleepMillis(Integer.MAX_VALUE); assertFalse("Capable of acquiring an additional permit after sleeping", r.tryAcquire()); } public void testSimpleRateUpdate() { RateLimiter limiter = RateLimiter.create(5.0, 5, SECONDS); assertEquals(5.0, limiter.getRate()); limiter.setRate(10.0);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 21.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
assertFalse("Capable of acquiring an additional permit", r.tryAcquire()); stopwatch.sleepMillis(Integer.MAX_VALUE); assertFalse("Capable of acquiring an additional permit after sleeping", r.tryAcquire()); } public void testSimpleRateUpdate() { RateLimiter limiter = RateLimiter.create(5.0, 5, SECONDS); assertEquals(5.0, limiter.getRate()); limiter.setRate(10.0);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 21.6K bytes - Viewed (0) -
src/runtime/profbuf.go
type profAtomic uint64 // A profIndex is the packet tag and data counts and flags bits, described above. type profIndex uint64 const ( profReaderSleeping profIndex = 1 << 32 // reader is sleeping and must be woken up profWriteExtra profIndex = 1 << 33 // overflow or eof waiting ) func (x *profAtomic) load() profIndex { return profIndex(atomic.Load64((*uint64)(x))) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 18.2K bytes - Viewed (0) -
docs/tls/README.md
``` # X.509 Certificate options # # DN options # The organization of the subject. organization = "Example Inc." # The organizational unit of the subject. #unit = "sleeping dept." # The state of the certificate owner. state = "Example" # The country of the subject. Two letter code. country = "EX" # The common name of the certificate owner. cn = "Sally Certowner"
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Sep 29 04:28:45 UTC 2022 - 8.4K bytes - Viewed (0)