- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 1,285 for threaded (0.17 sec)
-
pkg/kubelet/cm/cpumanager/topology/topology.go
} // getUniqueCoreID computes coreId as the lowest cpuID // for a given Threads []int slice. This will assure that coreID's are // platform unique (opposite to what cAdvisor reports) func getUniqueCoreID(threads []int) (coreID int, err error) { if len(threads) == 0 { return 0, fmt.Errorf("no cpus provided") } if len(threads) != cpuset.New(threads...).Size() { return 0, fmt.Errorf("cpus provided are not unique") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 03 16:26:09 UTC 2023 - 7.9K bytes - Viewed (0) -
src/internal/trace/traceviewer/format/format.go
) type GoroutineCountersArg struct { Running uint64 Runnable uint64 GCWaiting uint64 } type ThreadCountersArg struct { Running int64 InSyscall int64 } type ThreadIDArg struct { ThreadID uint64
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 21 20:45:06 UTC 2023 - 2K bytes - Viewed (0) -
src/internal/trace/testtrace/validation.go
v.gs[id] = state } // Validate sched context. if new.Executing() { ctx := v.getOrCreateThread(e, ev, ev.Thread()) if ctx != nil { if ctx.G != trace.NoGoroutine && ctx.G != id { e.Errorf("tried to run goroutine %d when one was already executing (%d) on thread %d", id, ctx.G, ev.Thread()) } ctx.G = id state.binding = ctx } } else if old.Executing() && !new.Executing() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 10.9K bytes - Viewed (0) -
src/internal/trace/order.go
G GoID P ProcID M ThreadID } // validateCtx ensures that ctx conforms to some reqs, returning an error if // it doesn't. func validateCtx(ctx schedCtx, reqs event.SchedReqs) error { // Check thread requirements. if reqs.Thread == event.MustHave && ctx.M == NoThread { return fmt.Errorf("expected a thread but didn't have one") } else if reqs.Thread == event.MustNotHave && ctx.M != NoThread {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 03 14:56:25 UTC 2024 - 52.4K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/api/tasks/bundling/ConcurrentArchiveIntegrationTest.groovy
then: // we should have extracted the file into a different directory for each extracter file("build/extract/thread_0/file.txt").assertExists() file("build/extract/thread_1/file.txt").assertExists() file("build/extract/thread_2/file.txt").assertExists() cleanup: handle?.abort() server.stop() }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 20 17:32:21 UTC 2024 - 28.6K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/operations/DefaultBuildOperationQueue.java
signalNoMoreWork(); // Use this thread to process any work - this allows work to be executed using the // worker lease acquired by this thread even if the executor thread pool is full of // workers from other queues. In other words, it ensures that all worker leases // are being utilized, regardless of the bounds of the thread pool. new WorkerRunnable().run();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jan 31 15:18:20 UTC 2023 - 10.4K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/util/internal/DisconnectableInputStream.java
static class ThreadExecuter implements Action<Runnable> { @Override public void execute(Runnable runnable) { Thread thread = new Thread(runnable); thread.setName("DisconnectableInputStream source reader"); thread.setDaemon(true); thread.start(); } } public DisconnectableInputStream(InputStream source) { this(source, 1024); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 07 08:18:46 UTC 2021 - 6.5K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/classpath/InstrumentedGroovyCallsTracker.java
/** * Matches the current thread's innermost instrumented call as intercepted, after which it cannot be discovered with * {@link InstrumentedGroovyCallsTracker#findCallerForCurrentCallIfNotIntercepted}. * * @throws IllegalStateException if the provided callable name and kind do not match the current thread's innermost call, or if the call has already been marked as intercepted.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Jul 24 15:57:59 UTC 2023 - 3.4K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/UnitOfWorkParticipant.java
package org.gradle.cache; /** * Participates in a unit of work that accesses the cache. Implementations do not need to be thread-safe and are accessed by a single thread at a time. */ public interface UnitOfWorkParticipant { /** * Called just after the cache is locked. Called before any work is performed by other threads. This method may access the cache files. * * @param currentCacheState the current cache state. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:08:47 UTC 2023 - 1.5K bytes - Viewed (0) -
tensorflow/cc/training/coordinator.h
bool AllRunnersStopped(); /// Requests all running threads to stop. Status RequestStop(); /// Returns true if its RequestStop() has been called. bool ShouldStop(); /// Joins all threads, returns OK or the first reported and unexpected status. Status Join(); /// Reports status to the coordinator. This is usually called by threads. void ReportStatus(const Status& status);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Oct 12 08:49:52 UTC 2023 - 4.4K bytes - Viewed (0)