livelock.go

package main

import (
	"fmt"
	"sync"
	"time"
)

type BirOrnek struct {
	sync.Mutex
	isim       string
	kilitlendi bool
	deger      int
}

func lock(ornek *BirOrnek) {
	ornek.Lock()
	ornek.kilitlendi = true
}

func unlock(ornek *BirOrnek) {
	ornek.Unlock()
	ornek.kilitlendi = false
}

func toplamlariYazdir(wg *sync.WaitGroup, isim string, deger1 *BirOrnek, deger2 *BirOrnek) {
	defer wg.Done()

	var toplam int

	for i := 0; ; i++ {
		if i >= 10 {
			fmt.Printf("Goroutine tamamlandı: %d", i)
			return
		}

		fmt.Printf("%v tarafından %v kilitleniyor\n", isim, deger1.isim)
		lock(deger1)

		time.Sleep(1 * time.Second)

		if deger2.kilitlendi {
			fmt.Printf("%v, tarafından %v lock işlemi kaldırılıyor\n", isim, deger1.isim)
			unlock(deger2)
			fmt.Printf("%v: %v lock uygulandı, tekrar deneniyor\n", isim, deger2.isim)
			continue
		}

		fmt.Printf("%v tarafından %v kilitleniyor\n", isim, deger2.isim)
		lock(deger2)

		toplam = deger1.deger + deger2.deger
		fmt.Printf("%v, tarafından %v lock işlemi kaldırılıyor\n", isim, deger1.isim)
		unlock(deger1)

		fmt.Printf("%v, tarafından %v lock işlemi kaldırılıyor\n", isim, deger2.isim)
		unlock(deger2)
		break
	}

	fmt.Printf("Toplam: %d", toplam)
}

func main() {
	a := BirOrnek{isim: "a"}
	b := BirOrnek{isim: "b"}

	wg := sync.WaitGroup{}

	wg.Add(2)

	go toplamlariYazdir(&wg, "ilk-islem", &a, &b)
	go toplamlariYazdir(&wg, "ikinci-islem", &b, &a)

	wg.Wait()
}