Function TestSharedBufferConcurrent

shared_buffer_test.go:75–102

(t *testing.T)

}

func TestSharedBufferConcurrent(t *testing.T) {
	const threads = 10
	const iters = 200

	buf := NewSharedBuffer(3)
	done := make(chan bool)

	for i := 0; i < threads; i++ {
		go func() {
			ch := buf.NewChannel()
			for i := 0; i < iters; i++ {
				ch.In() <- i
				val := <-ch.Out()
				if val.(int) != i {
					t.Error("Mismatched value out of channel")
				}
			}
			ch.Close()
			done <- true
		}()
	}

	for i := 0; i < threads; i++ {
		<-done
	}
	close(done)
	buf.Close()
}

func ExampleSharedBuffer() {
	// never more than 3 elements in the pipeline at once