You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
22 lines
957 B
22 lines
957 B
package fanout
|
|
|
|
import "context"
|
|
|
|
// addCache 加缓存的例子
|
|
func addCache(c context.Context, id, value int) {
|
|
// some thing...
|
|
}
|
|
|
|
func Example() {
|
|
// 这里只是举个例子 真正使用的时候 应该用bm/rpc 传过来的context
|
|
var c = context.Background()
|
|
// 新建一个fanout 对象 名称为cache 名称主要用来上报监控和打日志使用 最好不要重复
|
|
// (可选参数) worker数量为1 表示后台只有1个线程在工作
|
|
// (可选参数) buffer 为1024 表示缓存chan长度为1024 如果chan慢了 再调用Do方法就会报错 设定长度主要为了防止OOM
|
|
cache := New("cache", Worker(1), Buffer(1024))
|
|
// 需要异步执行的方法
|
|
// 这里传进来的c里面的meta信息会被复制 超时会忽略 addCache拿到的context已经没有超时信息了
|
|
cache.Do(c, func(c context.Context) { addCache(c, 0, 0) })
|
|
// 程序结束的时候关闭fanout 会等待后台线程完成后返回
|
|
cache.Close()
|
|
}
|
|
|