Function doTestParallelReaders

sync2/boundedrwlock_test.go:80–118

(gomaxprocs, numReaders int)

}

func doTestParallelReaders(gomaxprocs, numReaders int) {
	runtime.GOMAXPROCS(gomaxprocs)

	var rwl *BoundedRWLock = NewBoundedRWLock(int(numReaders))
	clocked := make(chan bool)
	cunlock := make(chan bool)
	cdone := make(chan bool)

	reader := func() {
		if err := rwl.RLock(100 * time.Millisecond); err != nil {
			panic(fmt.Sprintf("contention??"))
		}

		clocked <- true
		<-cunlock
		rwl.RUnlock()
		cdone <- true
	}

	// kick off parallel readers
	for i := 0; i < numReaders; i++ {
		go reader()
	}

	// wait for them to all acquire the rlock
	for i := 0; i < numReaders; i++ {
		<-clocked
	}

	// ask them to unlock
	for i := 0; i < numReaders; i++ {
		cunlock <- true
	}

	// wait for them to unlock
	for i := 0; i < numReaders; i++ {
		<-cdone
	}
}

func (suite *BoundedRWLockSuite) TestParallelReaders(t *C) {
	// restore the original value after we are done with the test