deadlock.go

package x2

import (
	"fmt"
	"sync"
	"testing"
)


type simpleDeadlock struct {
	mu *sync.RWMutex
	list []int
}

func (s *simpleDeadlock) FillCache() error {
	s.mu.Lock()
	defer s.mu.Unlock()

	s.list = []int{0,1,2,3,4}

	return nil
}

func (s *simpleDeadlock) GetCache() error {
	s.mu.RLock()
	defer s.mu.RUnlock()

	for _, i := range s.list {
		s.checkCache(i)
	}
	return nil
}

func (s *simpleDeadlock) checkCache(i int) int {
	s.mu.RLock()
	defer s.mu.RUnlock()

	return s.list[i]
}

func TestDeadlock(t *testing.T) {
	srv := &simpleDeadlock{
		mu: &sync.RWMutex{},
	}

	go func() {
		i := 0
		for {
			i++
			fmt.Println("FillCache", i)
			srv.FillCache()
		}
	}()
	i := 0
	for {
		i++
		fmt.Println("GetCache", i)
		srv.GetCache()
	}
}