- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 875 for channel2 (0.12 sec)
-
hack/testdata/deployment-label-change2.yaml
Davanum Srinivas <******@****.***> 1652185809 -0400
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 31 14:16:53 UTC 2022 - 377 bytes - Viewed (0) -
src/sync/cond.go
// a call to [Cond.Broadcast] or [Cond.Signal] “synchronizes before” any Wait call // that it unblocks. // // For many simple use cases, users will be better off using channels than a // Cond (Broadcast corresponds to closing a channel, and Signal corresponds to // sending on a channel). // // For more on replacements for [sync.Cond], see [Roberto Clapis's series on // advanced concurrency patterns], as well as [Bryan Mills's talk on concurrency
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 4.1K bytes - Viewed (0) -
test/cmp6.go
_ []int a float64 } var t4 T4 func main() { // Arguments to comparison must be // assignable one to the other (or vice versa) // so chan int can be compared against // directional channels but channel of different // direction cannot be compared against each other. var c1 chan<- int var c2 <-chan int var c3 chan int use(c1 == c2) // ERROR "invalid operation|incompatible"
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Dec 01 21:49:31 UTC 2020 - 2.2K bytes - Viewed (0) -
test/ken/chan.go
// run all test with 4 buffser sizes func main() { tests(0) tests(1) tests(10) tests(100) t := 4 * // buffer sizes (4*4 + // tests 1,2,3,4 channels 8 + // test 5 channels 12) * // test 6 channels 76 // sends/recvs on a channel if tots != t || totr != t { print("tots=", tots, " totr=", totr, " sb=", t, "\n") os.Exit(1) } os.Exit(0)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Feb 24 05:24:24 UTC 2012 - 4.7K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/tools/go/analysis/passes/sigchanyzer/sigchanyzer.go
return } pass.Report(analysis.Diagnostic{ Pos: call.Pos(), End: call.End(), Message: "misuse of unbuffered os.Signal channel as argument to signal.Notify", SuggestedFixes: []analysis.SuggestedFix{{ Message: "Change to buffer channel", TextEdits: []analysis.TextEdit{{ Pos: chanDecl.Pos(), End: chanDecl.End(), NewText: buf.Bytes(), }}, }}, }) })
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 09 01:28:01 UTC 2023 - 3.8K bytes - Viewed (0) -
guava/src/com/google/common/io/ByteStreams.java
* <ol> * <li>Use sendfile(2) or equivalent. Requires that both the input channel and the output * channel have their own file descriptors. Generally this only happens when both channels * are files or sockets. This performs zero copies - the bytes never enter userspace. * <li>Use mmap(2) or equivalent. Requires that either the input channel or the output channel
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Jan 17 18:59:58 UTC 2024 - 29.7K bytes - Viewed (0) -
src/os/signal/doc.go
On Windows a ^C (Control-C) or ^BREAK (Control-Break) normally cause the program to exit. If Notify is called for [os.Interrupt], ^C or ^BREAK will cause [os.Interrupt] to be sent on the channel, and the program will not exit. If Reset is called, or Stop is called on all channels passed to Notify, then the default behavior will be restored. Additionally, if Notify is called, and Windows sends CTRL_CLOSE_EVENT,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 18:11:00 UTC 2024 - 11K bytes - Viewed (0) -
android/guava/src/com/google/common/io/ByteStreams.java
* <ol> * <li>Use sendfile(2) or equivalent. Requires that both the input channel and the output * channel have their own file descriptors. Generally this only happens when both channels * are files or sockets. This performs zero copies - the bytes never enter userspace. * <li>Use mmap(2) or equivalent. Requires that either the input channel or the output channel
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Jan 17 18:59:58 UTC 2024 - 29.7K bytes - Viewed (0) -
pkg/istio-agent/xds_proxy.go
// the control plane requires substantial changes. Instead, we make the requests channel // unbounded. This is the least likely to cause issues as the messages we store here are the // smallest relative to other channels. requestsChan: channels.NewUnbounded[*discovery.DiscoveryRequest](),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 22:12:28 UTC 2024 - 27.9K bytes - Viewed (0) -
src/runtime/time.go
t.unlock() return } t.trace("maybeRunChan+") systemstack(func() { t.unlockAndRun(now) }) } // blockTimerChan is called when a channel op has decided to block on c. // The caller holds the channel lock for c and possibly other channels. // blockTimerChan makes sure that c is in a timer heap, // adding it if needed. func blockTimerChan(c *hchan) { t := c.timer t.lock()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 29 14:36:24 UTC 2024 - 37.5K bytes - Viewed (0)