- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 1,285 for threaded (0.34 sec)
-
src/internal/trace/testdata/generators/go122-confuse-seq-across-generations.go
g1 := t.Generation(1) // A running goroutine blocks. b10 := g1.Batch(trace.ThreadID(0), 0) b10.Event("ProcStatus", trace.ProcID(0), go122.ProcRunning) b10.Event("GoStatus", trace.GoID(1), trace.ThreadID(0), go122.GoRunning) b10.Event("GoStop", "whatever", testgen.NoStack) // The running goroutine gets unblocked. b11 := g1.Batch(trace.ThreadID(1), 0) b11.Event("ProcStatus", trace.ProcID(1), go122.ProcRunning)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 21:15:28 UTC 2024 - 2.1K bytes - Viewed (0) -
src/internal/trace/event.go
} // ExperimentalBatch represents a packet of unparsed data along with metadata about that packet. type ExperimentalBatch struct { // Thread is the ID of the thread that produced a packet of data. Thread ThreadID // Data is a packet of unparsed data all produced by one thread. Data []byte } // Event represents a single event in the trace. type Event struct { table *evTable ctx schedCtx
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 12:39:00 UTC 2024 - 28.9K bytes - Viewed (0) -
src/runtime/testdata/testprogcgo/threadprof.go
#include <stdint.h> #include <stdlib.h> #include <signal.h> #include <pthread.h> volatile int32_t spinlock; // Note that this thread is only started if GO_START_SIGPROF_THREAD // is set in the environment, which is only done when running the // CgoExternalThreadSIGPROF test. static void *thread1(void *p) { (void)p; while (spinlock == 0) ; pthread_kill(pthread_self(), SIGPROF); spinlock = 0; return NULL; }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Sep 05 22:43:54 UTC 2023 - 2.4K bytes - Viewed (0) -
maven-compat/src/main/java/org/apache/maven/artifact/resolver/DefaultArtifactResolver.java
private final Executor executor; public DefaultArtifactResolver() { int threads = Integer.getInteger("maven.artifact.threads", 5); if (threads <= 1) { executor = Runnable::run; } else { executor = new ThreadPoolExecutor( threads, threads, 3, TimeUnit.SECONDS, new LinkedBlockingQueue<>(), new DaemonThreadCreator()); } }
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Thu Apr 25 05:46:50 UTC 2024 - 24.8K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/execution/plan/DefaultPlanExecutor.java
// // This situation can happen when the last task in an included build is executed by the thread that called process() and all other workers are waiting for work to be enabled in the // other builds in the tree. The thread will signal the other threads and then stop running as a worker. At this point in time, work will be ready to start but all the (other) workers will
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 29.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/UncaughtExceptionHandlers.java
/** * Returns an exception handler that exits the system. This is particularly useful for the main * thread, which may start up other, non-daemon threads, but fail to fully initialize the * application successfully. * * <p>Example usage: * * <pre> * public static void main(String[] args) { * Thread.currentThread().setUncaughtExceptionHandler(UncaughtExceptionHandlers.systemExit()); * ... * </pre> *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Dec 14 20:35:03 UTC 2023 - 2.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java
* example involving two locks and two threads, deadlock occurs when one thread acquires Lock A, and * then Lock B, while another thread acquires Lock B, and then Lock A: * * <pre> * Thread1: acquire(LockA) --X acquire(LockB) * Thread2: acquire(LockB) --X acquire(LockA) * </pre> * * <p>Neither thread will progress because each is waiting for the other. In more complex
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Dec 15 19:31:54 UTC 2023 - 35.9K bytes - Viewed (0) -
src/runtime/cgo/callbacks.go
// interceptors, such as processing pending signals under the thread // sanitizer. // // Left as a nil pointer if no libc interceptors are expected. //go:cgo_import_static _cgo_yield //go:linkname _cgo_yield _cgo_yield var _cgo_yield unsafe.Pointer //go:cgo_export_static _cgo_topofstack //go:cgo_export_dynamic _cgo_topofstack // x_cgo_getstackbound gets the thread's C stack size and
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 17 21:53:11 UTC 2023 - 5.6K bytes - Viewed (0) -
platforms/core-configuration/model-core/src/main/java/org/gradle/internal/model/CalculatedValue.java
* Note that some other thread may currently be calculating the value even if this method returns false. */ boolean isFinalized(); /** * Calculates the value, if not already calculated. Collects any exception and does not rethrow them. * Blocks until the value is finalized, either by this thread or some other thread. */ void finalizeIfNotAlready(); /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 18 08:26:24 UTC 2024 - 2.2K bytes - Viewed (0) -
src/internal/trace/batch.go
"internal/trace/event/go122" ) // timestamp is an unprocessed timestamp. type timestamp uint64 // batch represents a batch of trace events. // It is unparsed except for its header. type batch struct { m ThreadID time timestamp data []byte exp event.Experiment } func (b *batch) isStringsBatch() bool { return b.exp == event.NoExperiment && len(b.data) > 0 && event.Type(b.data[0]) == go122.EvStrings }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 2.9K bytes - Viewed (0)