เขียน Go เรียกใช้ resource เดียวกันแต่ไม่อยากใช้ Exclusive Lock มีทางไหนบ้าง 🤔

package main

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

func main() {
	const (
		items      		= int[]{1, 2, 3, 4, 5, 6, 7}
		producerSleep   = 100 * time.Millisecond
		consumerSleep   = 150 * time.Millisecond
		channelBuffer   = 2 // ขนาดของ channel buffer สำหรับ producer กับ consumer
	)

	dataChannel := make(chan int, channelBuffer)
	var wg sync.WaitGroup

	wg.Add(2) // สร้างคิวรอ 2 goroutine

	go producer(dataChannel, items, producerSleep, &wg)
	go consumer(dataChannel, consumerSleep, &wg)

	wg.Wait() // รอจนกว่า goroutine ทั้ง 2 จะทำงานเสร็จ
}

func veryLongTask(input int, sleepDuration time.Duration) (output int, err error) {
	output = input * 2
	time.Sleep(sleepDuration, sleepDuration)
	return
}

func producer(ch chan<- int, items int[], sleepDuration time.Duration, wg *sync.WaitGroup) {
	defer wg.Done()
	for item := range items {
		// ส่งไปทำงาน
		output, _ := veryLongTask(item, sleepDuration)
		ch <- output // ทำงานเสร็จส่งข้อมูลเข้า channel
		fmt.Println("Produced:", i)
	}
	close(ch) // ส่งข้อมูลหมดแล้วก็ปิด channel
}

func consumer(ch <-chan int, sleepDuration time.Duration, wg *sync.WaitGroup) {
	defer wg.Done()
	for data := range ch {
		// รับข้อมูลจาก channel
		fmt.Println("Consumed:", data)
		time.Sleep(sleepDuration)
	}
}

package main

import (
	"fmt"
	"sync"
)

func main() {
	var m sync.Map

	// เก็บข้อมูล
	m.Store("key1", "value1")
	m.Store("key2", "value2")

	// อ่านข้อมูล
	m.Range(func(key, value interface{}) bool {
		fmt.Println(key, value)
		return true
	})
}

package main

import (
	"fmt"
	"sync"
	"sync/atomic"
)

func main() {
	var counter int64
	var wg sync.WaitGroup

	for i := 0; i < 1000; i++ {
		wg.Add(1)
		go func() {
			defer wg.Done()
			atomic.AddInt64(&counter, 1) // เพิ่มค่าตัวแปร counter
		}()
	}

	wg.Wait() // รอให้ Goroutine ทุกตัวทำงานเสร็จ
	fmt.Println("Final Counter:", counter)
}

package main

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

type SafeData struct {
	mu sync.RWMutex
	data int
}

func (s *SafeData) Read() int {
	s.mu.RLock() // ใช้ RLock สำหรับการอ่าน
	defer s.mu.RUnlock()
	return s.data
}

func (s *SafeData) Write(value int) {
	s.mu.Lock() // ใช้ Lock สำหรับการเขียน
	defer s.mu.Unlock()
	s.data = value
}

func main() {
	safeData := SafeData{}

	var wg sync.WaitGroup

	// Goroutine สำหรับเขียนข้อมูล
	wg.Add(1)
	go func() {
		defer wg.Done()
		for i := 0; i < 5; i++ {
			safeData.Write(i)
			fmt.Println("Written:", i)
			time.Sleep(100 * time.Millisecond)
		}
	}()

	// Goroutine สำหรับอ่านข้อมูล
	for i := 0; i < 5; i++ {
		wg.Add(1)
		go func() {
			defer wg.Done()
			fmt.Println("Read:", safeData.Read())
			time.Sleep(50 * time.Millisecond)
		}()
	}

	wg.Wait() // รอให้ Goroutine ทุกตัวทำงานเสร็จ
}