Subversion Repositories openrisc

// $G $D/$F.go && $L $F.$A && ./$A.out

// 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)

}