- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 346 for threaded (0.13 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) -
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) -
src/bytes/buffer_test.go
yBytes := Repeat(y, growLen) allocs := testing.AllocsPerRun(100, func() { buf.Grow(growLen) buf.Write(yBytes) }) // Check no allocation occurs in write, as long as we're single-threaded. if allocs != 0 { t.Errorf("allocation occurred during write") } // Check that buffer has correct data. if !Equal(buf.Bytes()[0:startLen-readBytes], xBytes[readBytes:]) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 13:31:36 UTC 2024 - 18.6K bytes - Viewed (0) -
src/syscall/fs_wasip1.go
// calls NewFile for each fd. NewFile queries the non-blocking flag // but doesn't change it, even if the runtime supports non-blocking // stdio. Since WebAssembly modules are single-threaded, blocking // system calls temporarily halt execution of the module. If the // runtime supports non-blocking stdio, the Go runtime is able to // use the WASI net poller to poll for read/write readiness and is
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 19:57:43 UTC 2024 - 24.1K bytes - Viewed (0) -
pkg/controller/garbagecollector/garbagecollector.go
const ResourceResyncTime time.Duration = 0 // GarbageCollector runs reflectors to watch for changes of managed API // objects, funnels the results to a single-threaded dependencyGraphBuilder, // which builds a graph caching the dependencies among objects. Triggered by the // graph changes, the dependencyGraphBuilder enqueues objects that can
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.9K bytes - Viewed (0)