- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 1,377 for waitc (0.19 sec)
-
test/fixedbugs/issue54343.go
// Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. package main import "runtime" func main() { if wait() { panic("GC'd early") } m = nil if !wait() { panic("never GC'd") } } var m = New[int]().M func New[X any]() *T[X] { p := new(T[X]) runtime.SetFinalizer(p, func(*T[X]) { close(done) }) return p }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Aug 11 20:13:07 UTC 2022 - 695 bytes - Viewed (0) -
test/fixedbugs/issue46725.go
done := make(chan struct{}) runtime.SetFinalizer(s[0], func(p *T) { close(done) }) var h, _ interface{} = g(s[:]) if wait(done) { panic("GC'd early") } if h.([]*T)[0][0] != Jenny { panic("lost Jenny's number") } if !wait(done) { panic("never GC'd") } } func wait(done <-chan struct{}) bool { for i := 0; i < 10; i++ { runtime.GC() select { case <-done: return true
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Aug 11 20:13:07 UTC 2022 - 818 bytes - Viewed (0) -
pkg/kubelet/pluginmanager/pluginwatcher/plugin_watcher_test.go
} } func retryWithExponentialBackOff(initialDuration time.Duration, fn wait.ConditionFunc) error { backoff := wait.Backoff{ Duration: initialDuration, Factor: 3, Jitter: 0, Steps: 6, } return wait.ExponentialBackoff(backoff, fn) } func TestPluginRegistration(t *testing.T) { socketDir := initTempDir(t)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 04 06:56:50 UTC 2023 - 8K bytes - Viewed (0) -
src/os/signal/signal_test.go
c2 := make(chan os.Signal, 1) Notify(c2, syscall.SIGHUP) defer Stop(c2) // Send this process a SIGWINCH and wait for notification on c1. syscall.Kill(syscall.Getpid(), syscall.SIGWINCH) waitSig(t, c1, syscall.SIGWINCH) // Send this process a SIGHUP and wait for notification on c2. syscall.Kill(syscall.Getpid(), syscall.SIGHUP) waitSig(t, c2, syscall.SIGHUP)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Nov 09 15:34:56 UTC 2023 - 27.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/TimeLimiter.java
* @param timeoutDuration with timeoutUnit, the maximum length of time that callers are willing to * wait on each method call to the proxy * @param timeoutUnit with timeoutDuration, the maximum length of time that callers are willing to * wait on each method call to the proxy * @return a time-limiting proxy * @throws IllegalArgumentException if {@code interfaceType} is a regular class, enum, or
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri May 12 18:32:03 UTC 2023 - 8.3K bytes - Viewed (0) -
internal/config/batch/batch.go
config.KV{ Key: ReplicationWorkersWait, Value: "0ms", // No wait by default between each replication attempts. }, config.KV{ Key: KeyRotationWorkersWait, Value: "0ms", // No wait by default between each key rotation attempts. }, config.KV{ Key: ExpirationWorkersWait, Value: "0ms", // No wait by default between each expiration attempts. }, }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.7K bytes - Viewed (0) -
test/ken/chan.go
} // wait for outstanding tests to finish func wait() { runtime.Gosched() for changeNproc(0) != 0 { runtime.Gosched() } } // run all tests with specified buffer size func tests(c int) { ca := mkchan(c, 4) test1(ca[0]) test1(ca[1]) test1(ca[2]) test1(ca[3]) wait() test2(c) wait() test3(c) wait() test4(c)
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/syscall/zsysnum_freebsd_amd64.go
SYS_OPEN = 5 // { int open(char *path, int flags, int mode); } SYS_CLOSE = 6 // { int close(int fd); } SYS_WAIT4 = 7 // { int wait4(int pid, int *status, \ SYS_LINK = 9 // { int link(char *path, char *link); } SYS_UNLINK = 10 // { int unlink(char *path); } SYS_CHDIR = 12 // { int chdir(char *path); }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 16 01:17:28 UTC 2022 - 25.5K bytes - Viewed (0) -
platforms/documentation/docs/src/snippets/workerApi/waitForCompletion/kotlin/build.gradle.kts
} } // Wait for all asynchronous work submitted to this queue to complete before continuing workQueue.await() logger.lifecycle("Created ${outputDir.get().asFile.listFiles().size} reversed files in ${outputDir.get().asFile.toRelativeString(projectLayout.projectDirectory.asFile)}") // end::wait-for-completion[] } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Nov 27 17:53:42 UTC 2023 - 1.7K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/wait/doc.go
See the License for the specific language governing permissions and limitations under the License. */ // Package wait provides tools for polling or listening for changes // to a condition.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 11 14:09:48 UTC 2017 - 717 bytes - Viewed (0)