Phase 2: Advanced Coordination Primitives

package main

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

// PaymentGatewayManager: จัดการการเชื่อมต่อไปยัง Core Banking ด้วย sync.Once
type PaymentGatewayManager struct {
    once     sync.Once
    endpoint string
}

func (m *PaymentGatewayManager) Connect() {
    // Fast-path atomic check: ครั้งที่ 2 เป็นต้นไปจะใช้เวลาเพียง 1-2 ns โดยไม่แตะต้อง Mutex เลย!
    m.once.Do(func() {
        fmt.Println("[Init] Establishing secure TLS 1.3 socket to Core Banking...")
        m.endpoint = "tls://gateway.bank.internal:8443"
    })
}

// TransactionQueue: คิวธุรกรรมที่มีระบบส่งสัญญาณด้วย sync.Cond
type TransactionQueue struct {
    mu    sync.Mutex
    cond  *sync.Cond
    items []string
}

func NewTransactionQueue() *TransactionQueue {
    q := &TransactionQueue{}
    // สร้าง Cond โดยผูกเข้ากับ Mutex ตัวเดียวกันเสมอ
    q.cond = sync.NewCond(&q.mu)
    return q
}

// Push: เติมงานธุรกรรมเข้าคิว และส่งสัญญาณปลุก Worker 1 ตัว (Signal)
func (q *TransactionQueue) Push(txID string) {
    q.mu.Lock()
    defer q.mu.Unlock()

    q.items = append(q.items, txID)
    // Signal: ปลุก Goroutine ที่หลับรอคิวอยู่ตัวแรกสุด (FIFO)
    q.cond.Signal()
}

// Pop: ดึงงานออกจากคิว หากคิวว่าง จะหลับรอสัญญาณแบบ Zero-CPU
func (q *TransactionQueue) Pop() string {
    q.mu.Lock()
    defer q.mu.Unlock()

    // กฎเหล็ก: ต้องใช้ for loop ตรวจสอบเสมอ ห้ามใช้ if เด็ดขาด! ป้องกัน Spurious Wakeup
    for len(q.items) == 0 {
        // Wait() จะปลดล็อก mu ชั่วคราว และนำ Goroutine เข้าสู่สถานะ Park (หลับ)
        // เมื่อถูกปลุก มันจะกลับมาเข้าคิวเพื่อแย่ง Lock mu คืนก่อนรันบรรทัดถัดไป
        q.cond.Wait()
    }

    item := q.items[0]
    q.items = q.items[1:]
    return item
}

type WaitGroup struct {
    noCopy noCopy        // 0 Bytes: Marker สำหรับตรวจจับ go vet copylocks
    state  atomic.Uint64 // 8 Bytes: รวม Counter (32 บิตบน) และ Waiter Count (32 บิตล่าง)
    sema   uint32        // 4 Bytes: Semaphore สำหรับ Sleep/Wakeup ผู้รอใน Wait()
}

// 2. src/sync/once.go (ขนาด 12 ไบต์ + Mutex)
type Once struct {
    done uint32     // 4 Bytes: Atomic Flag (0 = ยังไม่รัน, 1 = รันเสร็จแล้ว)
    m    Mutex      // 8 Bytes: sync.Mutex ปกป้องช่วง Slow-Path
}

// 3. src/sync/cond.go (ขนาด 32 ไบต์)
type Cond struct {
    noCopy  noCopy      // 0 Bytes: ห้าม copy
    L       Locker      // 16 Bytes: interface iface ชี้ไปยัง Mutex/RWMutex
    notify  notifyList  // 16 Bytes: คิวควบคุมการปลุก Goroutines
    checker copyChecker // 8 Bytes: ตรวจจับการ copy struct ขณะรันไทม์
}