mirror of
https://github.com/golang/go
synced 2024-11-25 03:27:58 -07:00
d2cc988429
X ,s;^// \$G (\$D/)?\$F\.go *$;// compile;g X ,s;^// \$G (\$D/)?\$F\.go && \$L \$F\.\$A *$;// build;g X ,s;^// \$G (\$D/)?\$F\.go && \$L \$F\.\$A && \./\$A\.out *$;// run;g X ,s;^// errchk \$G( -e)? (\$D/)?\$F\.go *$;// errorcheck;g R=golang-dev, bradfitz CC=golang-dev https://golang.org/cl/5673079
54 lines
817 B
Go
54 lines
817 B
Go
// run
|
|
|
|
// Copyright 2009 The Go Authors. All rights reserved.
|
|
// Use of this source code is governed by a BSD-style
|
|
// license that can be found in the LICENSE file.
|
|
|
|
package main
|
|
|
|
import "runtime"
|
|
|
|
const N = 1000 // sent messages
|
|
const M = 10 // receiving goroutines
|
|
const W = 2 // channel buffering
|
|
var h [N]int // marking of send/recv
|
|
|
|
func r(c chan int, m int) {
|
|
for {
|
|
select {
|
|
case r := <-c:
|
|
if h[r] != 1 {
|
|
println("r",
|
|
"m=", m,
|
|
"r=", r,
|
|
"h=", h[r])
|
|
panic("fail")
|
|
}
|
|
h[r] = 2
|
|
}
|
|
}
|
|
}
|
|
|
|
func s(c chan int) {
|
|
for n := 0; n < N; n++ {
|
|
r := n
|
|
if h[r] != 0 {
|
|
println("s")
|
|
panic("fail")
|
|
}
|
|
h[r] = 1
|
|
c <- r
|
|
}
|
|
}
|
|
|
|
func main() {
|
|
c := make(chan int, W)
|
|
for m := 0; m < M; m++ {
|
|
go r(c, m)
|
|
runtime.Gosched()
|
|
}
|
|
runtime.Gosched()
|
|
runtime.Gosched()
|
|
s(c)
|
|
}
|