Function ExampleNew

lockmap/map_test.go:12–42

()

)

func ExampleNew() {
	m := New(1*time.Minute, &tomb.Tomb{})
	m.Tomb().Go(m.Run)

	output := ""

	done := make(chan struct{})
	waitOrWork := func() {
		promise, gotLock := m.WaitOrLock("foo", 10*time.Second)
		if gotLock {
			// We just grabbed a new lock, do work with it.
			<-time.After(100 * time.Millisecond)
			output = "done"

			// Once we're done, remove it, which will close the channel on the promise.
			m.Release("foo")
		} else {
			<-promise
			fmt.Println(output)
			close(done)
		}
	}

	// Either one could be trigger first
	go waitOrWork()
	go waitOrWork()

	<-done
	// Output:
	// done
}

const sweepInterval = 1 * time.Second
const ttl = sweepInterval / 3