文件名称：jq:jq 是一个简单的应用内作业队列库
文件大小：7KB
文件格式：ZIP
更新时间：2024-07-22 03:05:23
Go
知乎 jq 是 Go 中一个简单的作业队列库。 您可以编写自己的后端队列和队列管理器实现，使 jq 成为真正的分布式作业队列 :) jq.NewJq(queueName, queueManager, workerFunc) jq.Submit(bytes, onReturnValueFunc, onErrorFunc, isSync) 用法： func workerFunc(input []byte, ret chan<- []byte, done chan<- struct{}, err chan<- error) { ret <- []byte("world") ret <- []byte("world") ret <- []byte("world") done <- struct{}{} } func TestEnqueue(t *testing.T) { jq :
【文件预览】：
jq-master
----jq_redis_queue_test.go(498B)
----jq.go(5KB)
----job.go(546B)
----queue.go(842B)
----redis_queue.go(800B)
----LICENSE(1KB)
----README.md(742B)
----redis_queue_manager.go(1KB)
----queue_manager.go(1KB)
----jq_test.go(2KB)
----.gitignore(266B)