Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 875 for channel2 (0.12 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top