package main

import (
    "fmt"
    "time"
)

func producer(ch chan int) {
    for i := 0; i < 10; i++ {
        ch <- i
        fmt.Printf("Produced: %d\n", i)
        time.Sleep(100 * time.Millisecond)
    }
    // 這里沒有關(guān)閉通道，可能導(dǎo)致緩沖區(qū)泄漏
    // close(ch) 
}

func main() {
    ch := make(chan int, 5)
    go producer(ch)

    // 模擬只消費(fèi)部分?jǐn)?shù)據(jù)
    for i := 0; i < 3; i++ {
        num := <-ch
        fmt.Printf("Consumed: %d\n", num)
    }

    // 主線程提前退出，通道中的剩余數(shù)據(jù)未被消費(fèi)，導(dǎo)致緩沖區(qū)泄漏
    time.Sleep(2 * time.Second)
    fmt.Println("Main function exiting")
}

package main

import (
    "fmt"
    "net/http"
    "time"
)

// 請(qǐng)求緩沖區(qū)
var requestBuffer = make(chan *http.Request, 10)

func requestHandler(w http.ResponseWriter, r *http.Request) {
    // 將請(qǐng)求放入緩沖區(qū)
    select {
    case requestBuffer <- r:
        fmt.Fprintf(w, "Request queued successfully\n")
    default:
        http.Error(w, "Request buffer is full", http.StatusServiceUnavailable)
    }
}

func requestProcessor() {
    for {
        select {
        case req := <-requestBuffer:
            // 模擬請(qǐng)求處理
            fmt.Printf("Processing request: %s\n", req.URL.Path)
            time.Sleep(2 * time.Second)
        case <-time.After(5 * time.Second):
            // 超時(shí)處理
            fmt.Println("No requests in buffer for 5 seconds")
        }
    }
}

func main() {
    http.HandleFunc("/", requestHandler)

    // 啟動(dòng)請(qǐng)求處理 Goroutine
    go requestProcessor()

    // 啟動(dòng) Web 服務(wù)器
    if err := http.ListenAndServe(":8080", nil); err != nil {
        fmt.Println(err)
    }
}

package main

import (
    "fmt"
    "time"
)

func producer(ch chan int) {
    for i := 0; i < 10; i++ {
        ch <- i
        fmt.Printf("Produced: %d\n", i)
        time.Sleep(100 * time.Millisecond)
    }
    // 關(guān)閉通道
    close(ch)
}

func main() {
    ch := make(chan int, 5)
    go producer(ch)

    // 消費(fèi)通道中的所有數(shù)據(jù)
    for num := range ch {
        fmt.Printf("Consumed: %d\n", num)
    }

    fmt.Println("Main function exiting")
}

package main

import (
    "fmt"
    "time"
)

func producer(ch chan int) {
    for i := 0; i < 10; i++ {
        ch <- i
        fmt.Printf("Produced: %d\n", i)
        time.Sleep(100 * time.Millisecond)
    }
    close(ch)
}

func main() {
    ch := make(chan int, 5)
    go producer(ch)

    for {
        select {
        case num, ok := <-ch:
            if!ok {
                // 通道已關(guān)閉，退出循環(huán)
                fmt.Println("Channel is closed")
                break
            }
            fmt.Printf("Consumed: %d\n", num)
        case <-time.After(2 * time.Second):
            // 超時(shí)處理
            fmt.Println("Timeout: No data received in 2 seconds")
            break
        }
    }

    fmt.Println("Main function exiting")
}