Function TestSharedBufferMultiple

shared_buffer_test.go:33–73

(t *testing.T)

}

func TestSharedBufferMultiple(t *testing.T) {
	buf := NewSharedBuffer(3)

	ch1 := buf.NewChannel()
	ch2 := buf.NewChannel()

	ch1.In() <- (*int)(nil)
	ch1.In() <- (*int)(nil)
	ch1.In() <- (*int)(nil)

	select {
	case ch2.In() <- (*int)(nil):
		t.Error("Wrote to full shared-buffer")
	case <-ch2.Out():
		t.Error("Read from empty channel")
	default:
	}

	<-ch1.Out()

	for i := 0; i < 10; i++ {
		ch2.In() <- (*int)(nil)

		select {
		case ch1.In() <- (*int)(nil):
			t.Error("Wrote to full shared-buffer")
		case ch2.In() <- (*int)(nil):
			t.Error("Wrote to full shared-buffer")
		default:
		}

		<-ch2.Out()
	}

	<-ch1.Out()
	<-ch1.Out()

	ch1.Close()
	ch2.Close()
	buf.Close()
}

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