Phase 2: Channel Multiplexing & Runtime selectgo

package main

import (
    "context"
    "fmt"
    "time"
)

type PaymentResult struct {
    TxID   string
    Status string
}

// MultiplexPaymentListener: ฟังผลลัพธ์จาก Primary Channel, Secondary Channel หรือ Timeout
func MultiplexPaymentListener(ctx context.Context, primary <-chan PaymentResult, secondary <-chan PaymentResult) {
    // 1. สร้าง Reusable Timer เพื่อป้องกัน Memory Leak จาก time.After()
    timeoutTimer := time.NewTimer(100 * time.Millisecond)
    defer timeoutTimer.Stop()

    for {
        select {
        case tx, ok := <-primary:
            if !ok {
                fmt.Println("[Listener] Primary gateway closed. Disabling branch...")
                primary = nil // 2. Nil Channel Trick: ปิดการทำงานของ case นี้ทันที!
                continue
            }
            fmt.Printf("[Primary Gateway] Settled: %s (%s)\n", tx.TxID, tx.Status)
            return

        case tx, ok := <-secondary:
            if !ok {
                fmt.Println("[Listener] Secondary gateway closed. Disabling branch...")
                secondary = nil // 2. Nil Channel Trick
                continue
            }
            fmt.Printf("[Secondary Gateway] Settled: %s (%s)\n", tx.TxID, tx.Status)
            return

        case <-timeoutTimer.C:
            fmt.Println("[Timeout] Settle decision exceeded 100ms threshold! Triggering Circuit Breaker.")
            return

        case <-ctx.Done():
            fmt.Println("[Cancellation] Upstream context cancelled. Aborting.")
            return

        default:
            // 3. Non-blocking branch: หากไม่มี channel ใดพร้อม จะกระโดดมาที่นี่ทันทีโดยไม่บล็อก
            // มักใช้ในการตรวจเช็กแบบ Polling หรือ Fire-and-Forget
            // ข้อควรระวัง: หากใส่ default ใน for loop จะกลายเป็น Busy-Wait กิน CPU 100% ทันที!
            time.Sleep(10 * time.Millisecond)
        }
    }
}

type scase struct {
    c    *hchan         // 8 Bytes: Pointer ชี้ไปยัง Channel ตัวจริงบน Heap
    elem unsafe.Pointer // 8 Bytes: Pointer ชี้ไปยัง Buffer ใน Stack ของ Goroutine สำหรับรับ/ส่ง
    kind uint16         // 2 Bytes: ประเภท Case (caseNil, caseRecv, caseSend, caseDefault)
    _    [6]byte        // 6 Bytes: Compiler Padding ให้ครบ 8 Bytes Alignment
}

// พารามิเตอร์หลักที่ถูกส่งเข้า runtime.selectgo
func selectgo(cas0 *scase, order0 *uint16, pc0 *uintptr, nsends, nrecvs int, block bool) (chosen int, ok bool) {
    // cas0: Array ของ scase ทั้งหมดใน select บล็อกนั้น
    // pollorder: Array ขนาดเท่าจำนวน cases เก็บ index ที่ถูก Shuffle แบบสุ่ม
    // lockorder: Array ขนาดเท่าจำนวน cases เก็บ index ที่จัดเรียงตาม Memory Address ของ hchan
    ...
}