Go语言并发编程:通道、信号量与同步原语
1. 工作池(Pool of workers)
通道可以作为资源池,允许我们按需请求资源。下面通过一个示例来展示如何创建一个小应用,使用github.com/tatsushid/go-fastping包中的第三方客户端,查找网络中的有效地址。
工作池有两个方法:
-Get:尝试从通道获取现有客户端,如果没有则返回一个新客户端。
-Put:尝试将客户端放回通道,否则丢弃。
const wait = time.Millisecond * 250 type pingPool chan *fastping.Pinger func (p pingPool) Get() *fastping.Pinger { select { case v := <-p: return v case <-time.After(wait): return fastping.NewPinger() } } func (p pingPool) Put(v *fastping.Pinger) { select { case p <- v: case <-time.After(wait): } return }客户端需要指定要扫描的网络,首先使用net.Interfaces函数获取可用网络列表,然后遍历