- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 866 for cancel3b (0.32 sec)
-
pkg/controller/tainteviction/timed_workers.go
timer := clock.AfterFunc(delay, fWithErrorLogging) return &TimedWorker{ WorkItem: args, CreatedAt: createdAt, FireAt: fireAt, Timer: timer, } } // Cancel cancels the execution of function by the `TimedWorker` func (w *TimedWorker) Cancel() { if w != nil { w.Timer.Stop() } } // TimedWorkerQueue keeps a set of TimedWorkers that are still wait for execution. type TimedWorkerQueue struct { sync.Mutex
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:23:56 UTC 2023 - 4.8K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
} catch (TimeoutException expected) { } finally { latch.countDown(); } } /** * Tests that a canceled future throws a cancellation exception. * * <p>This method checks the cancel, isCancelled, and isDone methods. */ public void testCanceledFutureThrowsCancellation() throws Exception { assertFalse(future.isDone());
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 18:30:30 UTC 2023 - 6K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/integTest/groovy/org/gradle/launcher/daemon/DaemonReuseIntegrationTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 10.1K bytes - Viewed (0) -
.github/workflows/mint.yml
name: Mint Tests on: pull_request: branches: - master # This ensures that previous jobs for the PR are canceled when the PR is # updated. concurrency: group: ${{ github.workflow }}-${{ github.head_ref }} cancel-in-progress: true permissions: contents: read jobs: mint-test: runs-on: mint timeout-minutes: 120 steps:
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 04 15:12:57 UTC 2024 - 2.9K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/server/DaemonStateCoordinatorTest.groovy
final Runnable onStartCommand = Mock(Runnable) final Runnable onFinishCommand = Mock(Runnable) boolean canceled = false final Runnable onCancelCommand = new Runnable() { @Override void run() { canceled = true; } } final coordinator = new DaemonStateCoordinator(executorFactory, onStartCommand, onFinishCommand, onCancelCommand, 2000)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sun May 05 22:24:02 UTC 2024 - 16.3K bytes - Viewed (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
} catch (TimeoutException expected) { } finally { latch.countDown(); } } /** * Tests that a canceled future throws a cancellation exception. * * <p>This method checks the cancel, isCancelled, and isDone methods. */ public void testCanceledFutureThrowsCancellation() throws Exception { assertFalse(future.isDone());
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 18:30:30 UTC 2023 - 6K bytes - Viewed (0) -
src/os/signal/signal_test.go
} cancelParent() <-c.Done() if got := c.Err(); got != context.Canceled { t.Errorf("c.Err() = %q, want %q", got, context.Canceled) } } func TestNotifyContextPrematureCancelParent(t *testing.T) { parent, cancelParent := context.WithCancel(context.Background()) defer cancelParent() cancelParent() // Prematurely cancel context before calling NotifyContext. c, stop := NotifyContext(parent, syscall.SIGINT)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Nov 09 15:34:56 UTC 2023 - 27.2K bytes - Viewed (0) -
platforms/ide/tooling-api/src/testFixtures/groovy/org/gradle/integtests/tooling/fixture/ContinuousBuildToolingApiSpecification.groovy
println jstackOutput println "--------------------------------------------------" } } } boolean cancel() { cancellationTokenSource.cancel() waitUntilOutputContains anyOf(containsString(BUILD_CANCELLED), containsString(BUILD_CANCELLED_AND_STOPPED)) true } void waitBeforeModification(File file) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 9.1K bytes - Viewed (0) -
src/net/http/transport_dial_test.go
func (dt *transportDialTester) roundTrip() *transportDialTesterRoundTrip { dt.t.Helper() ctx, cancel := context.WithCancel(context.Background()) pr, pw := io.Pipe() rt := &transportDialTesterRoundTrip{ t: dt.t, roundTripID: dt.roundTripCount, done: make(chan struct{}), reqBody: pw, cancel: cancel, } dt.roundTripCount++ dt.t.Logf("RoundTrip %v: started", rt.roundTripID)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 17 21:11:57 UTC 2024 - 6.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher.go
} case <-watchClosedCh: case <-wc.ctx.Done(): // user cancel } // We use wc.ctx to reap all goroutines. Under whatever condition, we should stop them all. // It's fine to double cancel. wc.cancel() // we need to wait until resultChan wouldn't be used anymore resultChanWG.Wait() close(wc.resultChan) } func (wc *watchChan) Stop() { wc.cancel() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 25 10:26:38 UTC 2023 - 18.9K bytes - Viewed (0)