Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 566 for yielded (0.18 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top