Test Distributed Lock

main.go

package main

import (
	"fmt"
	goredislib "github.com/go-redis/redis"
	"github.com/go-redsync/redsync/v3"
	"github.com/go-redsync/redsync/v3/redis"
	"github.com/go-redsync/redsync/v3/redis/goredis"
	"sync"
	"time"
)

func main() {
	wg := sync.WaitGroup{}
	samples := 50
	var failed = 0
	var num = 0
	sampleChannel := make(chan string)

	for i := 0; i < samples; i++ {
		wg.Add(1)
		go func() {
			rdb := goredislib.NewClient(&goredislib.Options{
				Addr:     "localhost:56379",
				Password: "",
				DB:       0,
			})
			defer rdb.Close()

			pool := goredis.NewGoredisPool(rdb)
			rs := redsync.New([]redis.Pool{pool})
			mutex := rs.NewMutex("test-redsync", redsync.SetTries(1))

			<-sampleChannel

			if err := mutex.Lock(); err == nil {
				time.Sleep(time.Second * 1)
				num++
				mutex.Unlock()
			} else {
				failed++
			}

			wg.Done()
		}()
	}

	close(sampleChannel)
	wg.Wait()

	fmt.Printf("Failed: %d\nSucceed: %d\nSamples: %d\n\n", failed, num, samples)

}