Go语言中泄漏缓冲区的问题解决

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 i := 0; i < 3; i++ {
        num := <-ch
        fmt.Printf("Consumed: %d\n", num)
    }

    // 主线程提前退出，通道中的剩余数据未被消费，导致缓冲区泄漏
    time.Sleep(2 * time.Second)
    fmt.Println("Main function exiting")
}

package main

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

// 请求缓冲区
var requestBuffer = make(chan *http.Request, 10)

func requestHandler(w http.ResponseWriter, r *http.Request) {
    // 将请求放入缓冲区
    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:
            // 模拟请求处理
            fmt.Printf("Processing request: %s\n", req.URL.Path)
            time.Sleep(2 * time.Second)
        case <-time.After(5 * time.Second):
            // 超时处理
            fmt.Println("No requests in buffer for 5 seconds")
        }
    }
}

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

    // 启动请求处理 Goroutine
    go requestProcessor()

    // 启动 Web 服务器
    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)
    }
    // 关闭通道
    close(ch)
}

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

    // 消费通道中的所有数据
    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 {
                // 通道已关闭，退出循环
                fmt.Println("Channel is closed")
                break
            }
            fmt.Printf("Consumed: %d\n", num)
        case <-time.After(2 * time.Second):
            // 超时处理
            fmt.Println("Timeout: No data received in 2 seconds")
            break
        }
    }

    fmt.Println("Main function exiting")
}