- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 1,378 for rerunning (0.12 sec)
-
src/internal/trace/testdata/generators/go122-go-create-without-running-g.go
testgen "internal/trace/internal/testgen/go122" ) func main() { testgen.Main(gen) } func gen(t *testgen.Trace) { g1 := t.Generation(1) // A goroutine gets created on a running P, then starts running. b0 := g1.Batch(trace.ThreadID(0), 0) b0.Event("ProcStatus", trace.ProcID(0), go122.ProcRunning) b0.Event("GoCreate", trace.GoID(5), testgen.NoStack, testgen.NoStack)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 21:15:28 UTC 2024 - 996 bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
private final CountDownLatch stopLatch = new CountDownLatch(1); private volatile boolean running = false; @Override public @Nullable Void call() throws InterruptedException { running = true; startLatch.countDown(); stopLatch.await(); running = false; return null; } public void waitForStart() throws InterruptedException {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 16.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
private final CountDownLatch stopLatch = new CountDownLatch(1); private volatile boolean running = false; @Override public @Nullable Void call() throws InterruptedException { running = true; startLatch.countDown(); stopLatch.await(); running = false; return null; } public void waitForStart() throws InterruptedException {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 16.8K bytes - Viewed (0) -
src/runtime/coro.go
// will take back its thread-lock state before returning. gdestroy(gp) gp = nil } else { // If we can CAS ourselves directly from running to waiting, so do, // keeping the control transfer as lightweight as possible. gp.waitreason = waitReasonCoroutine if !gp.atomicstatus.CompareAndSwap(_Grunning, _Gwaiting) { // The CAS failed: use casgstatus, which will take care of
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 19:09:18 UTC 2024 - 7.4K bytes - Viewed (0) -
src/internal/trace/order.go
} if state.status != go122.GoRunning { return curCtx, false, fmt.Errorf("%s event for goroutine that's not %s", go122.EventString(ev.typ), GoRunning) } // Goroutine entered a syscall. It's still running on this P and M. state.status = go122.GoSyscall pState, ok := o.pStates[curCtx.P] if !ok {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 03 14:56:25 UTC 2024 - 52.4K bytes - Viewed (0) -
src/internal/trace/testdata/generators/go122-syscall-steal-proc-reacquire-new-proc.go
func gen(t *testgen.Trace) { g := t.Generation(1) // One goroutine enters a syscall, grabs a P, and starts running. b0 := g.Batch(trace.ThreadID(0), 0) b0.Event("ProcStatus", trace.ProcID(1), go122.ProcIdle) b0.Event("ProcStatus", trace.ProcID(0), go122.ProcRunning) b0.Event("GoStatus", trace.GoID(1), trace.ThreadID(0), go122.GoRunning) b0.Event("GoSyscallBegin", testgen.Seq(1), testgen.NoStack)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 21:15:28 UTC 2024 - 1.1K bytes - Viewed (0) -
src/runtime/tracestatus.go
switch pp.status { case _Pidle, _Pgcstop: status = traceProcIdle if pp.status == _Pgcstop && inSTW { // N.B. a P that is running and currently has the world stopped will be // in _Pgcstop, but we model it as running in the tracer. status = traceProcRunning } case _Prunning: status = traceProcRunning // There's a short window wherein the goroutine may have entered _Gsyscall
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 17:03:35 UTC 2024 - 7.2K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/it/CrawlTestBase.java
} logger.info("Crawler is running"); count = 0; isRunning = true; while (count < 300 && isRunning) { // Wait until the crawler terminates ThreadUtil.sleep(1000); count++; final Map<String, Object> scheduler = getSchedulerItem(namePrefix); assertTrue(scheduler.containsKey("running")); isRunning = (Boolean) scheduler.get("running"); }
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 9.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Dispatcher.kt
val idleCallback: Runnable? this.withLock { if (!calls.remove(call)) throw AssertionError("Call wasn't in-flight!") idleCallback = this.idleCallback } val isRunning = promoteAndExecute() if (!isRunning && idleCallback != null) { idleCallback.run() } } /** Returns a snapshot of the calls currently awaiting execution. */ fun queuedCalls(): List<Call> =
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 9K bytes - Viewed (0) -
src/runtime/preempt.go
// count and the scheduler skips suspended // goroutines? That wouldn't be enough for // {_Gsyscall,_Gwaiting} -> _Grunning. Maybe // for all those transitions we need to check // suspended and deschedule? return suspendGState{g: gp, stopped: stopped} case _Grunning: // Optimization: if there is already a pending preemption request // (from the previous loop iteration), don't bother with the atomics.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 15:41:45 UTC 2024 - 15.1K bytes - Viewed (0)