- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 677 for threaded (0.12 sec)
-
subprojects/core/src/integTest/groovy/org/gradle/internal/operations/logging/LoggingBuildOperationProgressIntegTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri May 17 13:27:34 UTC 2024 - 17.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/tlsconfig.go
newContent, err := c.newTLSContent() if err != nil { return err } // if the content is the same as what we currently have, we can simply skip it. This works because we are single // threaded. If you ever make this multi-threaded, add a lock. if newContent.Equal(c.currentlyServedContent) { return nil } // make a shallow copy and override the dynamic pieces which have changed.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 10.3K bytes - Viewed (0) -
maven-embedder/src/main/java/org/apache/maven/cli/transfer/ConsoleMavenTransferListener.java
import org.eclipse.aether.transfer.TransferEvent; import org.eclipse.aether.transfer.TransferResource; /** * Console download progress meter. * <p> * This listener is not thread-safe and should be wrapped in the {@link SimplexTransferListener} in a multi-threaded scenario. */ public class ConsoleMavenTransferListener extends AbstractMavenTransferListener {
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Jun 11 21:48:41 UTC 2024 - 5.1K bytes - Viewed (0) -
samples/bookinfo/src/productpage/productpage.py
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 14:35:54 UTC 2024 - 14.6K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ExecutionList.java
/** Logger to log exceptions caught when running runnables. */ private static final LazyLogger log = new LazyLogger(ExecutionList.class); /** * The runnable, executor pairs to execute. This acts as a stack threaded through the {@link * RunnableExecutorPair#next} field. */ @GuardedBy("this") @CheckForNull private RunnableExecutorPair runnables; @GuardedBy("this") private boolean executed;
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 22 21:17:24 UTC 2024 - 6.9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionList.java
/** Logger to log exceptions caught when running runnables. */ private static final LazyLogger log = new LazyLogger(ExecutionList.class); /** * The runnable, executor pairs to execute. This acts as a stack threaded through the {@link * RunnableExecutorPair#next} field. */ @GuardedBy("this") @CheckForNull private RunnableExecutorPair runnables; @GuardedBy("this") private boolean executed;
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 22 21:17:24 UTC 2024 - 6.9K bytes - Viewed (0) -
src/syscall/exec_unix.go
// accidentally inherits the write end of a pipe, then the reader // of that pipe will not see EOF until that child exits, potentially // causing the parent program to hang. This is a common problem // in threaded C programs that use popen. // // Luckily, the file descriptors that are most important not to // inherit are not the ones that can take an arbitrarily long time // to create: pipe returns instantly, and the net package uses
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 26 21:03:59 UTC 2024 - 8.7K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/execution/taskgraph/DefaultTaskExecutionGraph.java
*/ return executionPlan.getContents().getFilteredTasks(); } private void fireWhenReady() { // We know that we're running single-threaded here, so we can use coarse grained project locks gradleInternal.getOwner().getProjects().withMutableStateOfAllProjects( () -> buildOperationRunner.run(
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Mar 08 13:46:07 UTC 2024 - 15.2K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/cidrallocator.go
if !cache.WaitForCacheSync(c.internalStopCh, c.serviceCIDRSynced, c.ipAddressSynced) { runtime.HandleError(fmt.Errorf("timed out waiting for caches to sync")) return } // this is single threaded only one serviceCIDR at a time go wait.Until(c.runWorker, time.Second, c.internalStopCh) <-c.internalStopCh } func (c *MetaAllocator) runWorker() { for c.processNextItem() { } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 13.2K bytes - Viewed (0) -
doc/go_mem.html
*p += i </pre> <p> If <code>i</code> and <code>*p</code> start equal to 2, the original code does <code>*p = 3</code>, so a racing thread can read only 2 or 3 from <code>*p</code>. The rewritten code does <code>*p = 1</code> and then <code>*p = 3</code>, allowing a racing thread to read 1 as well. </p> <p> Note that all these optimizations are permitted in C/C++ compilers:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 04 15:54:42 UTC 2024 - 26.6K bytes - Viewed (0)