go gearman:戈朗工作调度员 源码

齿轮手 分片密钥散列到同一队列,每个队列都绑定到一个工作器。 用法 初始装备 gm := gearman . NewGearman ( workerNum , queueSize , SetIdleTimeout ( 1 * time . Minute ), SetExceptionCall ( func ( error ))) 开始/停止 gm . Start () defer gm . Stop () 提交 gm . Submit ( shardingKey , func () error ) 例子 package main import ( "fmt" "sync" "github.com/rfyiamcool/go-gearman" ) func main () { gm := gearman . NewGearman ( 10 , 1000 ) gm . Start