- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 553 for delay (0.04 sec)
-
src/runtime/netpoll_aix.go
// Returns list of goroutines that become runnable. // delay < 0: blocks indefinitely // delay == 0: does not block, just polls // delay > 0: block for up to that many nanoseconds // //go:nowritebarrierrec func netpoll(delay int64) (gList, int32) { var timeout uintptr if delay < 0 { timeout = ^uintptr(0) } else if delay == 0 { // TODO: call poll with timeout == 0 return gList{}, 0
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 5.1K bytes - Viewed (0) -
platforms/core-runtime/concurrent/src/main/java/org/gradle/internal/concurrent/ManagedScheduledExecutorImpl.java
} @Override public ScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) { return delegate.schedule(trackedCommand(command), delay, unit); } @Override public <V> ScheduledFuture<V> schedule(Callable<V> callable, long delay, TimeUnit unit) { return delegate.schedule(trackedCommand(callable), delay, unit); } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:35 UTC 2024 - 1.9K bytes - Viewed (0) -
src/runtime/netpoll_windows.go
// delay < 0: blocks indefinitely // delay == 0: does not block, just polls // delay > 0: block for up to that many nanoseconds func netpoll(delay int64) (gList, int32) { if iocphandle == _INVALID_HANDLE_VALUE { return gList{}, 0 } var entries [64]overlappedEntry var wait uint32 var toRun gList mp := getg().m if delay >= 1e15 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 19:58:28 UTC 2024 - 9.4K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
this.delay = delay; this.unit = checkNotNull(unit); } /** * @param delay the time from now to delay execution * @since 31.1 */ public Schedule(Duration delay) { this(toNanosSaturated(delay), NANOSECONDS); } } /** * Calculates the time at which to next invoke the task. *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Dec 13 19:45:20 UTC 2023 - 27.5K bytes - Viewed (0) -
samples/jwt-server/src/main.go
// Add artificious delay based on delay query delayParam := request.URL.Query().Get("delay") if delayParam != "" { delayDuration, err := time.ParseDuration(delayParam) if err != nil { // Handle invalid delay parameter response.WriteHeader(http.StatusBadRequest) response.Write([]byte("Invalid delay parameter")) return } // If delay parameter is provided and valid, add delay
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 16 23:56:50 UTC 2024 - 4.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
* A value object that represents an absolute delay until a task should be invoked. * * @author Luke Sandberg * @since 11.0 */ protected static final class Schedule { private final long delay; private final TimeUnit unit; /** * @param delay the time from now to delay execution * @param unit the time unit of the delay parameter */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Dec 13 19:45:20 UTC 2023 - 25.8K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/managedfields/internal/atmostevery_test.go
import ( "testing" "time" "k8s.io/apimachinery/pkg/util/managedfields/internal" ) func TestAtMostEvery(t *testing.T) { duration := time.Second delay := 179 * time.Millisecond atMostEvery := internal.NewAtMostEvery(delay) count := 0 exit := time.NewTicker(duration) tick := time.NewTicker(2 * time.Millisecond) defer exit.Stop() defer tick.Stop() done := false for !done { select {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 08 21:44:00 UTC 2023 - 1.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/WrappingScheduledExecutorServiceTest.java
long lastDelay; TimeUnit lastUnit; void assertLastMethodCalled(String method, long delay, TimeUnit unit) { assertEquals(method, lastMethodCalled); assertEquals(delay, lastDelay); assertEquals(unit, lastUnit); } void assertLastMethodCalled(String method, long initialDelay, long delay, TimeUnit unit) { assertEquals(method, lastMethodCalled);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Dec 16 19:54:45 UTC 2020 - 7.6K bytes - Viewed (0) -
src/runtime/lock_js.go
//go:yeswritebarrierrec func beforeIdle(now, pollUntil int64) (gp *g, otherReady bool) { delay := int64(-1) if pollUntil != 0 { // round up to prevent setTimeout being called early delay = (pollUntil-now-1)/1e6 + 1 if delay > 1e9 { // An arbitrary cap on how long to wait for a timer. // 1e9 ms == ~11.5 days. delay = 1e9 } } if delay > 0 && (idleTimeout == nil || idleTimeout.diff(pollUntil) > 1e6) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 21 21:02:20 UTC 2023 - 7.3K bytes - Viewed (0) -
src/runtime/netpoll_kqueue.go
// delay < 0: blocks indefinitely // delay == 0: does not block, just polls // delay > 0: block for up to that many nanoseconds func netpoll(delay int64) (gList, int32) { if kq == -1 { return gList{}, 0 } var tp *timespec var ts timespec if delay < 0 { tp = nil } else if delay == 0 { tp = &ts } else { ts.setNsec(delay) if ts.tv_sec > 1e6 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 12 21:17:22 UTC 2024 - 4.6K bytes - Viewed (0)