- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 566 for yielded (0.18 sec)
-
src/runtime/sema_test.go
func testSemaHandoff() bool { var sema, res uint32 done := make(chan struct{}) // We're testing that the current goroutine is able to yield its time slice // to another goroutine. Stop the current goroutine from migrating to // another CPU where it can win the race (and appear to have not yielded) by // keeping the CPUs slightly busy. var wg sync.WaitGroup for i := 0; i < GOMAXPROCS(-1); i++ { wg.Add(1) go func() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 21 19:37:22 UTC 2022 - 4.2K bytes - Viewed (0) -
docs/en/docs/tutorial/dependencies/dependencies-with-yield.md
## A database dependency with `yield` For example, you could use this to create a database session and close it after finishing. Only the code prior to and including the `yield` statement is executed before creating a response: ```Python hl_lines="2-4" {!../../../docs_src/dependencies/tutorial007.py!} ``` The yielded value is what is injected into *path operations* and other dependencies:
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sat Feb 24 23:06:37 UTC 2024 - 14.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
} }); // Run those tasks together. fakePool.runAll(); // Check that the interruption of a SequentialExecutor's task is restored to the thread once // it is yielded. Clear the bit while checking so that the test doesn't hose JUnit or some other // test case. assertThat(Thread.interrupted()).isTrue(); } public void testInterrupt_doesNotStopExecution() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 11.4K bytes - Viewed (0) -
src/internal/trace/traceviewer/http.go
at the final moment when it yielded the logical processor, for example because it made a system call or tried to acquire a mutex. Directly underneath each bar, a smaller bar or more commonly a fine vertical line indicates an event occurring during its execution. Some of these are related to garbage collection; most indicate that a goroutine yielded its logical processor but then immediately resumed execution
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 21 21:29:53 UTC 2023 - 12.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
} }); // Run those tasks together. fakePool.runAll(); // Check that the interruption of a SequentialExecutor's task is restored to the thread once // it is yielded. Clear the bit while checking so that the test doesn't hose JUnit or some other // test case. assertThat(Thread.interrupted()).isTrue(); } public void testInterrupt_doesNotStopExecution() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 11.4K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/executor_island_coarsening.cc
// Add associated inner op result to operands of the YieldOp. yield_operands.push_back(old_result.inner_op_result); } // Create YieldOp for the new island. OpBuilder builder(&new_island.GetBody(), new_island.GetBody().end()); return builder.create<YieldOp>(new_island.getLoc(), yield_operands); } // Moves inner ops (excluding last op/YieldOp) from islands being merged into // the new merged island.
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 25 16:01:03 UTC 2024 - 19.7K bytes - Viewed (0) -
test/range4.go
package main var gj int func yield4x(yield func() bool) { _ = yield() && yield() && yield() && yield() } func yield4(yield func(int) bool) { _ = yield(1) && yield(2) && yield(3) && yield(4) } func yield3(yield func(int) bool) { _ = yield(1) && yield(2) && yield(3) } func yield2(yield func(int) bool) { _ = yield(1) && yield(2) } func testfunc0() { j := 0
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jan 08 16:00:53 UTC 2024 - 5.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset.go
// This is our generalization of the progress meter named R in the original fair queuing work. currentR fqrequest.SeatSeconds // lastRealTime is what `clock.Now()` yielded when `virtualTime` was last updated lastRealTime time.Time // robinIndex is the index of the last queue dispatched robinIndex int // totRequestsWaiting is the sum, over all the queues, of the
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 04 16:59:21 UTC 2024 - 42.4K bytes - Viewed (0) -
src/internal/trace/order.go
newCtx := curCtx switch ev.typ { case go122.EvGoDestroy: // This goroutine is exiting itself. delete(o.gStates, curCtx.G) newCtx.G = NoGoroutine case go122.EvGoStop: // Goroutine stopped (yielded). It's runnable but not running on this M. state.status = go122.GoRunnable newCtx.G = NoGoroutine case go122.EvGoBlock: // Goroutine blocked. It's waiting now and not running on this M.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 03 14:56:25 UTC 2024 - 52.4K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/ir/tf_ops_n_z.cc
// if they are yielded they always have to be forwarded 1:1. auto forwarded_operands = cond_yield->getOperands().drop_front(1); for (auto [arg, yield] : llvm::zip(op.getCond().getArguments(), forwarded_operands)) { if (arg != yield) { return op.emitOpError() << "arguments on condition block aren't forwarded to yield"; } } }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu May 09 22:07:10 UTC 2024 - 170.8K bytes - Viewed (0)