Go语言中并发安全的结构体数组管理：使用Goroutine和Channel

package main

import (
    "fmt"
    "net/http"
    "github.com/ant0ine/go-json-rest/rest" // 假设使用此REST框架
)

// Item 定义要存储的结构体
type Item struct {
    Name string `json:"name"`
}

// ItemRequest 用于请求当前Item列表的结构体
type ItemRequest struct {
    Response chan []Item // 用于接收Item列表的响应通道
}

// ItemHolder 负责并发安全地管理Item列表
type ItemHolder struct {
    items   []Item        // 实际存储Item的切片
    Input   chan Item     // 用于接收新Item的输入通道
    Request chan ItemRequest // 用于接收Item列表请求的通道
}

// Run 启动ItemHolder的事件循环，处理输入和请求
func (ih *ItemHolder) Run() {
    for {
        select {
        case req := <-ih.Request:
            // 接收到请求，将当前items列表发送回请求通道
            req.Response <- ih.items
        case in := <-ih.Input:
            // 接收到新Item，将其追加到列表中
            ih.items = append(ih.items, in)
        }
    }
}

// itemHolder 作为全局变量，提供对ItemHolder实例的访问
var itemHolder = &ItemHolder{
    Request: make(chan ItemRequest), // 初始化请求通道
    Input:   make(chan Item),        // 初始化输入通道
}

// Add 处理POST请求，添加新的Item
func Add(w *rest.ResponseWriter, req *rest.Request) {
    data := Item{}
    err := req.DecodeJsonPayload(&data)
    if err != nil {
        rest.Error(w, err.Error(), http.StatusInternalServerError)
        return
    }

    // 将新Item发送到ItemHolder的输入通道
    itemHolder.Input <- data

    w.WriteHeader(http.StatusCreated) // 返回201 Created表示成功创建
    w.WriteJson(&data)
}

// GetItems 处理GET请求，获取所有Item
func GetItems(w *rest.ResponseWriter, req *rest.Request) {
    // 创建一个用于接收响应的通道
    responseChannel := make(chan []Item)
    // 发送请求给ItemHolder
    itemHolder.Request <- ItemRequest{Response: responseChannel}

    // 从响应通道中获取Item列表
    currentItems := <-responseChannel

    w.WriteJson(&currentItems)
}

// 示例：在非API函数中打印当前Item列表
func PrintCurrentItems() {
    responseChannel := make(chan []Item)
    itemHolder.Request <- ItemRequest{Response: responseChannel}
    fmt.Println("当前 Items:", <-responseChannel)
}

func main() {
    // 启动ItemHolder的Goroutine
    go itemHolder.Run()

    handler := rest.ResourceHandler{
        EnableRelaxedContentType: true,
    }
    handler.SetRoutes(
        rest.Route{"POST", "/add", Add},
        rest.Route{"GET", "/items", GetItems}, // 示例：添加一个获取所有Item的路由
    )

    fmt.Println("Server started on :8080")
    http.ListenAndServe(":8080", &handler)
}