Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 470 for channel (0.2 sec)

  1. src/main/java/org/codelibs/core/nio/ChannelUtil.java

         * @param channel
         *            ファイルチャネル。{@literal null}であってはいけません
         * @param mode
         *            モード。{@literal null}であってはいけません
         * @return ファイルチャネルをメモリにマップした{@link ByteBuffer}
         */
        public static ByteBuffer map(final FileChannel channel, final MapMode mode) {
            assertArgumentNotNull("channel", channel);
            assertArgumentNotNull("mode", mode);
    
            try {
    Java
    - Registered: Fri May 03 20:58:11 GMT 2024
    - Last Modified: Thu Mar 07 01:59:08 GMT 2024
    - 6K bytes
    - Viewed (0)
  2. cmd/service.go

    	// Close when we reach 0
    	globalServiceFreezeCnt--
    	if globalServiceFreezeCnt <= 0 {
    		// Set to a nil channel.
    		var _ch chan struct{}
    		if val := globalServiceFreeze.Swap(_ch); val != nil {
    			if ch, ok := val.(chan struct{}); ok && ch != nil {
    				// Close previous non-nil channel.
    				xioutil.SafeClose(ch)
    			}
    		}
    		globalServiceFreezeCnt = 0 // Don't risk going negative.
    	}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Feb 28 07:02:14 GMT 2024
    - 3.8K bytes
    - Viewed (0)
  3. doc/next/6-stdlib/1-time.md

    now unbuffered, with capacity 0.
    The main effect of this change is that Go now guarantees
    that for any call to a `Reset` or `Stop` method, no stale values
    prepared before that call will be sent or received after the call.
    Earlier versions of Go used channels with a one-element buffer,
    making it difficult to use `Reset` and `Stop` correctly.
    A visible effect of this change is that `len` and `cap` of timer channels
    Plain Text
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Apr 12 20:57:18 GMT 2024
    - 1.5K bytes
    - Viewed (0)
  4. .teamcity/src/test/kotlin/PerformanceTestBuildTypeTest.kt

            assertEquals(
                (
                    listOf(
                        "clean",
                        ":performance:largeTestProjectPerformanceTest --channel %performance.channel% ",
                        ":performance:smallTestProjectPerformanceTest --channel %performance.channel% ",
                        "extraParameters"
                    ) + expectedRunnerParams
                    ).joinToString(" "),
    Plain Text
    - Registered: Wed May 01 11:36:15 GMT 2024
    - Last Modified: Wed Apr 24 08:17:56 GMT 2024
    - 7.3K bytes
    - Viewed (0)
  5. doc/go_mem.html

    use a synchronization mechanism such as a lock or channel
    communication to establish a relative ordering.
    </p>
    
    <h3 id="chan">Channel communication</h3>
    
    <p>
    Channel communication is the main method of synchronization
    between goroutines.  Each send on a particular channel
    is matched to a corresponding receive from that channel,
    usually in a different goroutine.
    </p>
    
    <p class="rule">
    HTML
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Mon Mar 04 15:54:42 GMT 2024
    - 26.6K bytes
    - Viewed (0)
  6. src/builtin/builtin.go

    //	specified number of elements. The size may be omitted, in which case
    //	a small starting size is allocated.
    //	Channel: The channel's buffer is initialized with the specified
    //	buffer capacity. If zero, or the size is omitted, the channel is
    //	unbuffered.
    func make(t Type, size ...IntegerType) Type
    
    // The max built-in function returns the largest value of a fixed number of
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Thu Apr 11 20:22:45 GMT 2024
    - 12.7K bytes
    - Viewed (0)
  7. .teamcity/src/main/kotlin/configurations/PerformanceTestsPass.kt

                )
                param("env.PERFORMANCE_DB_PASSWORD_TCAGENT", "%performance.db.password.tcagent%")
                param("performance.db.username", "tcagent")
                param("performance.channel", performanceTestSpec.channel())
            }
    
            features {
                publishBuildStatusToGithub(model)
            }
    
            val performanceResultsDir = "perf-results"
            val performanceProjectName = "performance"
    
    Plain Text
    - Registered: Wed May 01 11:36:15 GMT 2024
    - Last Modified: Thu Apr 04 07:21:42 GMT 2024
    - 5.1K bytes
    - Viewed (0)
  8. manifests/charts/base/templates/validatingadmissionpolicy.yaml

              )
            )
    ---
    apiVersion: admissionregistration.k8s.io/v1
    kind: ValidatingAdmissionPolicyBinding
    metadata:
      name: "stable-channel-default-policy-binding.istio.io"
    spec:
      policyName: "stable-channel-default-policy.istio.io"
      validationActions: [Deny]
    Others
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Mon Apr 22 22:00:40 GMT 2024
    - 1.6K bytes
    - Viewed (0)
  9. .teamcity/src/main/kotlin/configurations/PerformanceTest.kt

                    allowEmpty = true,
                    description = "The baselines you want to run performance tests against. Empty means default baseline."
                )
                param("performance.channel", performanceTestBuildSpec.channel())
                param("env.PERFORMANCE_DB_PASSWORD_TCAGENT", "%performance.db.password.tcagent%")
                when (os) {
                    Os.WINDOWS -> param("env.PATH", "%env.PATH%;C:/Program Files/7-zip")
    Plain Text
    - Registered: Wed May 01 11:36:15 GMT 2024
    - Last Modified: Wed Apr 24 08:17:56 GMT 2024
    - 5.3K bytes
    - Viewed (0)
  10. internal/grid/stream.go

    type Stream struct {
    	// responses from the remote server.
    	// Channel will be closed after error or when remote closes.
    	// All responses *must* be read by the caller until either an error is returned or the channel is closed.
    	// Canceling the context will cause the context cancellation error to be returned.
    	responses <-chan Response
    	cancel    context.CancelCauseFunc
    
    	// Requests sent to the server.
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Wed Feb 28 18:05:18 GMT 2024
    - 2.8K bytes
    - Viewed (0)
Back to top