- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 1,285 for threaded (0.25 sec)
-
guava-tests/test/com/google/common/util/concurrent/UninterruptibleFutureTest.java
* * 1. The client thread begins to block on a get() call to a future. * 2. The client thread is interrupted sometime before the result would be * available. * 3. We expect the client's get() to throw an InterruptedException. * 4. We expect the client thread's interrupt state to be false. * 5. The client thread again makes a blocking call to get().
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 9.1K bytes - Viewed (0) -
tensorflow/cc/training/queue_runner.h
/// Requests to stop and runs the cancel op. It would be called in a separate /// thread when coordinator is set. If there is no coordinator it should be /// called before calling Join. void Stop(Session* sess); /// Joins all the threads. Returns okay if all threads run successfully; /// otherwise returns the first captured failure status. Status Join() final;
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Aug 31 18:27:00 UTC 2022 - 5K bytes - Viewed (0) -
src/internal/trace/internal/testgen/go122/trace.go
// Batch starts a new event batch in the trace data. // // This is convenience function for generating correct batches. func (g *Generation) Batch(thread trace.ThreadID, time Time) *Batch { if !g.trace.validTimestamps { time = 0 } b := &Batch{ gen: g, thread: thread, timestamp: time, } g.batches = append(g.batches, b) return b } // String registers a string with the trace. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 9.7K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/resources/AbstractResourceLockRegistryTest.groovy
when: lock.lockedState = true then: registry.hasOpenLocks() } def inNewThread(Closure closure) { def thread = new Thread(closure) thread.start() thread.join() } static class TestRegistry extends AbstractResourceLockRegistry<String, ResourceLock> { TestRegistry(ResourceLockCoordinationService coordinationService) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 2.6K bytes - Viewed (0) -
src/internal/trace/testdata/generators/go122-syscall-steal-proc-simple.go
// One goroutine enters a syscall. b0 := g.Batch(trace.ThreadID(0), 0) 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) b0.Event("GoSyscallEndBlocked") // A running goroutine steals proc 0. b1 := g.Batch(trace.ThreadID(1), 0) b1.Event("ProcStatus", trace.ProcID(2), go122.ProcRunning)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 21:15:28 UTC 2024 - 988 bytes - Viewed (0) -
src/internal/trace/oldtrace.go
events oldtrace.Events extra []Event extraArr [3]Event tasks map[TaskID]taskState seenProcs map[ProcID]struct{} lastTs Time procMs map[ProcID]ThreadID lastStwReason uint64 inlineToStringID []uint64 builtinToStringID []uint64 } const ( // Block reasons sForever = iota sPreempted sGosched sSleep sChanSend sChanRecv
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 17.2K bytes - Viewed (0) -
src/regexp/exec.go
m.clear(nextq) return m.matched } // clear frees all threads on the thread queue. func (m *machine) clear(q *queue) { for _, d := range q.dense { if d.t != nil { m.pool = append(m.pool, d.t) } } q.dense = q.dense[:0] } // step executes one step of the machine, running each of the threads // on runq and appending new threads to nextq. // The step processes the rune c (which may be endOfText),
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat Jun 04 20:10:54 UTC 2022 - 12.3K bytes - Viewed (0) -
src/internal/trace/testdata/generators/go122-syscall-steal-proc-gen-boundary-reacquire-new-proc.go
// acquired a new P. b0 := g.Batch(trace.ThreadID(0), 0) b0.Event("GoStatus", trace.GoID(1), trace.ThreadID(0), go122.GoSyscall) b0.Event("ProcStatus", trace.ProcID(1), go122.ProcIdle) b0.Event("ProcStart", trace.ProcID(1), testgen.Seq(1)) b0.Event("GoSyscallEndBlocked") // A running goroutine stole P0 at the generation boundary. b1 := g.Batch(trace.ThreadID(1), 0) b1.Event("ProcStatus", trace.ProcID(2), go122.ProcRunning)
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/internal/trace/testdata/generators/go122-create-syscall-with-p.go
g := t.Generation(1) // A C thread calls into Go and acquires a P. It returns // back to C, destroying the G. It then comes back to Go // on the same thread and again returns to C. // // Note: on pthread platforms this can't happen on the // same thread because the m is stashed in TLS between // calls into Go, until the thread dies. This is still // possible on other platforms, however.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 21:15:28 UTC 2024 - 1.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
return; } TimedWaiterThread thread = new TimedWaiterThread(new AbstractFuture<Object>() {}, 2, TimeUnit.SECONDS); thread.start(); thread.awaitWaiting(); thread.suspend(); // Sleep for enough time to add 1500 milliseconds of overwait to the get() call. long toWaitMillis = 3500 - TimeUnit.NANOSECONDS.toMillis(System.nanoTime() - thread.startTime); Thread.sleep(toWaitMillis);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 46.7K bytes - Viewed (0)