Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 787 for channel (0.34 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. maven-compat/src/main/java/org/apache/maven/repository/legacy/DefaultUpdateCheckManager.java

                    channel.truncate(0);
                    props.store(Channels.newOutputStream(channel), "Last modified on: " + new Date());
    
                    lock.release();
                    lock = null;
    
                    channel.close();
                    channel = null;
                } catch (IOException e) {
                    getLogger()
                            .debug(
    Java
    - Registered: Sun Apr 28 03:35:10 GMT 2024
    - Last Modified: Wed Sep 06 11:28:54 GMT 2023
    - 12.1K bytes
    - Viewed (0)
  4. 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)
  5. .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)
  6. 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)
  7. okhttp/src/test/java/okhttp3/SocketChannelTest.kt

                listOf(Channel, Standard).flatMap { socketMode ->
                  listOf(DISABLED, STANDARD).map { tlsExtensionMode ->
                    TlsInstance(provider, protocol, tlsVersion, socketMode, tlsExtensionMode)
                  }
                }
              }
            }
          } + Channel + Standard
      }
    }
    
    sealed class SocketMode
    
    object Channel : SocketMode() {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 8K bytes
    - Viewed (0)
  8. 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)
  9. .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)
  10. 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)
Back to top