- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 2,595 for stops (0.06 sec)
-
src/cmd/compile/internal/syntax/testdata/chans.go
// Next method to retrieve values. The Sender provides a Send method // to send values and a Close method to stop sending values. The Next // method indicates when the Sender has been closed, and the Send // method indicates when the Receiver has been freed. // // This is a convenient way to exit a goroutine sending values when // the receiver stops reading them. func Ranger[T any]() (*Sender[T], *Receiver[T]) { c := make(chan T) d := make(chan bool)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 30 18:02:18 UTC 2022 - 1.8K bytes - Viewed (0) -
src/debug/pe/string.go
// license that can be found in the LICENSE file. package pe import ( "bytes" "encoding/binary" "fmt" "internal/saferio" "io" ) // cstring converts ASCII byte sequence b to string. // It stops once it finds 0 or reaches end of b. func cstring(b []byte) string { i := bytes.IndexByte(b, 0) if i == -1 { i = len(b) } return string(b[:i]) } // StringTable is a COFF string table.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Sep 07 19:06:17 UTC 2023 - 1.8K bytes - Viewed (0) -
src/run.bash
# This environment variable is an internal implementation detail between the # Go build system (x/build) and cmd/dist for the purpose of longtest builders, # and will be removed if it stops being needed. See go.dev/issue/12508. # # GO_TEST_TIMEOUT_SCALE: a non-negative integer factor to scale test timeout by. # Defaults to 1. set -e if [ ! -f ../bin/go ]; then
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 15:02:23 UTC 2024 - 1.7K bytes - Viewed (0) -
platforms/enterprise/enterprise/src/main/java/org/gradle/internal/enterprise/impl/DefaultGradleEnterprisePluginBackgroundJobExecutors.java
* All executors immediately stops accepting new jobs. The method blocks until already submitted jobs complete. * * @throws RuntimeException any exception or error thrown by a job is rethrown from this method, potentially wrapped as a RuntimeException */ public void stop() { if (executorService.isShutdown()) { return; } executorService.stop(); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Feb 29 16:27:53 UTC 2024 - 3.8K bytes - Viewed (0) -
src/text/template/option.go
// If printed, the result of the index operation is the string // "<no value>". // "missingkey=zero" // The operation returns the zero value for the map type's element. // "missingkey=error" // Execution stops immediately with an error. func (t *Template) Option(opt ...string) *Template { t.init() for _, s := range opt { t.setOption(s) } return t } func (t *Template) setOption(opt string) { if opt == "" {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 11 16:34:30 UTC 2022 - 1.9K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/deployment/internal/DefaultDeploymentRegistryTest.groovy
when: registry.stop() then: 3 * testHandle.stop() } def "cannot get a handle once the registry is stopped" () { objectFactory.newInstance(TestDeploymentHandle) >> new TestDeploymentHandle() given: registry.start("id", DeploymentRegistry.ChangeBehavior.NONE, TestDeploymentHandle) registry.stop() when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Mar 08 13:46:07 UTC 2024 - 4.6K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/actor/Actor.java
* @return The proxy. */ <T> T getProxy(Class<T> type); /** * Stops accepting new method calls, and blocks until all method calls have been executed by the target object. * * @throws DispatchException When there were any failures dispatching method calls to the target object. */ @Override void stop() throws DispatchException;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 2.6K bytes - Viewed (0) -
pkg/backoff/exponential.go
return Option{ InitialInterval: defaultInitialInterval, MaxInterval: defaultMaxInterval, } } // NewExponentialBackOff creates an istio wrapped ExponentialBackOff. // By default, it never stops. func NewExponentialBackOff(o Option) BackOff { b := ExponentialBackOff{} b.exponentialBackOff = backoff.NewExponentialBackOff() b.exponentialBackOff.InitialInterval = o.InitialInterval
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 25 01:53:48 UTC 2023 - 3.1K bytes - Viewed (0) -
src/cmd/go/testdata/script/test_fuzz_io_error.txt
# Test that when the coordinator experiences an I/O error communicating # with a worker, the coordinator stops the worker and reports the error. # The coordinator should not record a crasher. # # We simulate an I/O error in the test by writing garbage to fuzz_out. # This is unlikely, but possible. It's difficult to simulate interruptions # due to ^C and EOF errors which are more common. We don't report those. [short] skip [!fuzz] skip env GOCACHE=$WORK/cache
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 16 16:53:11 UTC 2023 - 2.6K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/daemon/AbstractDaemonFixture.groovy
long getLogLineCount() { return daemonLog.lines().withCloseable { lines -> lines.count() } } DaemonFixture becomesIdle() { waitForState(Idle) this } DaemonFixture stops() { waitForState(Stopped) this } @Override void assertIdle() { assertHasState(Idle) } @Override void assertBusy() { assertHasState(Busy)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 15:22:16 UTC 2024 - 3.8K bytes - Viewed (0)