小鸡啄米路过

楚汉争霸

@wniming macbook 你值得拥有

@wniming 同架构的 qemu 虚拟机性能不差的

@xuanbg 要考虑跨协程共享和归还

@hsfzxjy 做泛型约束用的

@zhlxsh IT 精英还缺对象吗?

@Juppiter 思想不纯洁

封装个 GetConfig 方法, 替代直接访问

买云服务, 自己搭建的容易被扔到垃圾邮件

财富自由了吗, 全职搞开源

qq 群什么都能聊

对参数进行签名

@hopingtop 是我想得太简单了😂

@hopingtop 使用 json.Encoder/Decoder 就可以自己管理 buffer pool 了

@hopingtop 包装下 sync.Pool, 把大包扔掉就好了

看看这个, 无 channel 实现的任务队列, 搭配 WaitGroup 使用就符合你的需求了
https://github.com/lxzan/gws/blob/master/task.go

来个 star 吧, 泛型实现的任务队列

https://github.com/lxzan/concurrency

```go
package main

import (
"fmt"
"github.com/lxzan/concurrency"
"sync/atomic"
)

func main() {
sum := int64(0)
w := concurrency.NewWorkerGroup[int64]()
for i := int64(1); i <= 10; i++ {
w.Push(i)
}
w.OnMessage = func(args int64) error {
fmt.Printf("%v ", args)
atomic.AddInt64(&sum, args)
return nil
}
w.Start()
fmt.Printf("sum=%d\n", sum)
}
```

输出
```
4 5 6 7 8 9 10 1 3 2 sum=55
```

试试 unix socket ?
我这个库封装了 websocket 服务端和客户端, 支持 unix socket 作为传输层
https://github.com/lxzan/gws