- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 2,444 for done2 (0.17 sec)
-
src/internal/trace/testdata/testprog/stacks.go
select {} }() go func() { // func2 var c chan int c <- 0 }() go func() { // func3 var c chan int <-c }() done1 := make(chan bool) go func() { // func4 <-done1 }() done2 := make(chan bool) go func() { // func5 done2 <- true }() c1 := make(chan int) c2 := make(chan int) go func() { // func6 select { case <-c1: case <-c2: } }()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 2.4K bytes - Viewed (0) -
src/net/pipe.go
cn1 := make(chan int) cn2 := make(chan int) done1 := make(chan struct{}) done2 := make(chan struct{}) p1 := &pipe{ rdRx: cb1, rdTx: cn1, wrTx: cb2, wrRx: cn2, localDone: done1, remoteDone: done2, readDeadline: makePipeDeadline(), writeDeadline: makePipeDeadline(), } p2 := &pipe{ rdRx: cb2, rdTx: cn2, wrTx: cb1, wrRx: cn1, localDone: done2, remoteDone: done1,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 5.4K bytes - Viewed (0) -
src/time/tick_test.go
tim.Reset(10000 * Second) drainAsync() done = make(chan bool, 2) done1 := make(chan bool) done2 := make(chan bool) stop := make(chan bool) go func() { select { case <-C: done <- true case <-stop: } close(done1) }() go func() { select { case <-C: done <- true case <-stop: } close(done2) }() Sleep(sched) notDone(done)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 17:10:37 UTC 2024 - 14.7K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/api/internal/tasks/SnapshotTaskInputsOperationIntegrationTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 09:03:53 UTC 2024 - 23.5K bytes - Viewed (0) -
src/context/x_test.go
return c.donec } func TestCustomContextPropagation(t *testing.T) { cause := errors.New("TestCustomContextPropagation") donec := make(chan struct{}) ctx1, cancel1 := WithCancelCause(Background()) ctx2 := &customDoneContext{ Context: ctx1, donec: donec, } ctx3, cancel3 := WithCancel(ctx2) defer cancel3() cancel1(cause) close(donec) <-ctx3.Done()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 19:58:28 UTC 2024 - 26.3K bytes - Viewed (0) -
src/context/afterfunc_test.go
afterFuncs map[*byte]func() done chan struct{} err error } func newAfterFuncContext() context.Context { return &afterFuncContext{} } func (c *afterFuncContext) Deadline() (time.Time, bool) { return time.Time{}, false } func (c *afterFuncContext) Done() <-chan struct{} { c.mu.Lock() defer c.mu.Unlock() if c.done == nil { c.done = make(chan struct{}) } return c.done }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 16:58:52 UTC 2023 - 3.4K bytes - Viewed (0) -
test/stress/runstress.go
<-gate }() } } func ringf(in <-chan int, out chan<- int, donec chan bool) { for { var n int select { case <-donec: return case n = <-in: } if n == 0 { close(donec) return } out <- n - 1 } } func threadRing(bufsize int) { const N = 100 donec := make(chan bool) one := make(chan int, bufsize) // will be input to thread 1
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:21:35 UTC 2024 - 3.6K bytes - Viewed (0) -
src/runtime/memmove_loong64.s
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 13 15:04:25 UTC 2024 - 1.8K bytes - Viewed (0) -
src/runtime/memmove_mips64x.s
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat Nov 06 10:24:44 UTC 2021 - 1.8K bytes - Viewed (0) -
src/runtime/proc_test.go
<-done1 } else if dj >= dk && dj >= threshold { // divide in two by x axis mj := j0 + dj/2 done1 := make(chan struct{}, 1) go matmult(done1, A, B, C, i0, i1, j0, mj, k0, k1, threshold) matmult(nil, A, B, C, i0, i1, mj, j1, k0, k1, threshold) <-done1 } else if dk >= threshold { // divide in two by "k" axis // deliberately not parallel because of data races mk := k0 + dk/2
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 14 00:03:57 UTC 2023 - 25.8K bytes - Viewed (0)