- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 1,285 for threaded (0.18 sec)
-
src/encoding/gob/decoder.go
// That's okay, we'll store through the pointer. } else if !v.CanSet() { return errors.New("gob: DecodeValue of unassignable value") } } // Make sure we're single-threaded through here. dec.mutex.Lock() defer dec.mutex.Unlock() dec.buf.Reset() // In case data lingers from previous invocation. dec.err = nil id := dec.decodeTypeSequence(false) if dec.err == nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 08 19:04:28 UTC 2023 - 7.2K bytes - Viewed (0) -
platforms/core-runtime/logging/src/integTest/groovy/org/gradle/internal/logging/LoggingIntegrationTest.groovy
}} final LogOutput multiThreaded = new LogOutput() {{ (1..10).each { thread -> (1..100).each { iteration -> lifecycle("log message from thread $thread iteration $iteration") quiet("stdout message from thread $thread iteration $iteration") quiet("styled text message from thread $thread iteration $iteration") } } }}
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:05:18 UTC 2023 - 15.6K 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) -
tensorflow/compiler/mlir/lite/converter_gen.cc
"LogicalResult " "{\n" " // Consume only errors that are coming from the same thread " "in order not\n" " // to ignore errors from other passes that are running. Things\n" " // running\n" " // in the pass manager can be multi-threaded.\n" " return success(current_thread_id == llvm::get_threadid());\n" " });\n";
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Dec 19 15:05:28 UTC 2023 - 23.7K bytes - Viewed (0) -
src/encoding/gob/debug.go
errorf("debug: read error: %s", err) } deb.consumed(w) return n } // GobStream: // // DelimitedMessage* (until EOF) func (deb *debugger) gobStream() { // Make sure we're single-threaded through here. deb.mutex.Lock() defer deb.mutex.Unlock() for deb.delimitedMessage(0) { } } // DelimitedMessage: // // uint(lengthOfMessage) Message
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jan 20 09:34:41 UTC 2023 - 18.3K 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/cmd/compile/internal/inline/inlheur/scoring.go
// local 'cstab' entry in the fnInlHeur object for inlinable routines. // // NOTE: this assumes that inlining operations are happening in a serial, // single-threaded fashion,f which is true today but probably won't hold // in the future (for example, we might want to score the callsites // in multiple functions in parallel); if the inliner evolves in this
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 27 20:42:52 UTC 2024 - 24.2K 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)