- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 812 for pcancel (0.14 sec)
-
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/operations/BuildOperationQueue.java
*/ void add(T operation); /** * Cancels all queued operations in this queue. Any operations that have started will be allowed to complete. */ void cancel(); /** * Waits for all previously added operations to complete. * <p> * On failure, some effort is made to cancel any operations that have not started. *
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 2.1K bytes - Viewed (0) -
src/context/context.go
return contextName(c.Context) + ".WithCancel" } // cancel closes c.done, cancels each of c's children, and, if // removeFromParent is true, removes c from its parent's children. // cancel sets c.cause to cause if this is the first time c is canceled. func (c *cancelCtx) cancel(removeFromParent bool, err, cause error) { if err == nil { panic("context: internal error: missing cancel error") } if cause == nil { cause = err }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 19:58:28 UTC 2024 - 23.7K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/work/AsyncWorkCompletion.java
*/ void waitForCompletion(); /** * Returns true if the work item is completed. */ boolean isComplete(); /** * Cancels this work item. */ void cancel();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 14 16:55:12 UTC 2018 - 1017 bytes - Viewed (0) -
tensorflow/cc/training/queue_runner_test.cc
using ops::QueueDequeue; using ops::QueueEnqueue; using ops::RandomNormal; using ops::Square; using ops::Variable; constexpr char kAssignOpName[] = "assign"; constexpr char kCancelOp0[] = "cancel0"; constexpr char kCancelOp1[] = "cancel1"; constexpr char kCloseOp0[] = "close0"; constexpr char kCloseOp1[] = "close1"; constexpr char kCountUpToOpName[] = "count"; constexpr char kDequeueOp0[] = "dequeue0";
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Sat Sep 21 06:27:51 UTC 2019 - 14.7K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/ConditionalExecution.java
*/ void complete(); /** * Whether this execution has been completed or not. */ boolean isComplete(); /** * Cancels this execution. */ void cancel();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 1.2K bytes - Viewed (0) -
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) -
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) -
src/cmd/go/internal/script/state.go
if k, v, ok := strings.Cut(kv, "="); ok { envMap[k] = v } } s := &State{ ctx: ctx, cancel: cancel, workdir: absWork, pwd: absWork, env: env, envMap: envMap, } s.Setenv("PWD", absWork) return s, nil } // CloseAndWait cancels the State's Context and waits for any background commands to // finish. If any remaining background command ended in an unexpected state,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jan 31 20:33:02 UTC 2023 - 6.9K bytes - Viewed (0) -
src/net/http/client.go
} initialReqCancel := req.Cancel // the user's original Request.Cancel, if any var cancelCtx func() if timeBeforeContextDeadline(deadline, oldCtx) { req.ctx, cancelCtx = context.WithDeadline(oldCtx, deadline) } cancel := make(chan struct{}) req.Cancel = cancel doCancel := func() { // The second way in the func comment above: close(cancel) // The first way, used only for RoundTripper
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 06:06:11 UTC 2024 - 33.7K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
if err != nil { atomic.AddInt64(&h.failedMessages, 1) return } // Delete the event from store. return h.store.Del(key.Name) } // Cancel - cancels the target func (h *Target) Cancel() { // If queuestore is configured, cancel it's context to // stop the replay go-routine. if h.store != nil { h.storeCtxCancel() } // Set logch to nil and close it.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Jun 02 03:03:39 UTC 2024 - 10.2K bytes - Viewed (0)