提交 f952275b 作者: Juan Batiz-Benet

shorter queue test (reloaded)

上级 0f12f4b2
...@@ -74,19 +74,17 @@ func newPeerTime(t time.Time) peer.Peer { ...@@ -74,19 +74,17 @@ func newPeerTime(t time.Time) peer.Peer {
} }
func TestSyncQueue(t *testing.T) { func TestSyncQueue(t *testing.T) {
tickT := time.Microsecond * 100 tickT := time.Microsecond * 50
max := 10000 max := 5000
consumerN := 10 consumerN := 10
countsIn := make([]int, consumerN*2) countsIn := make([]int, consumerN*2)
countsOut := make([]int, consumerN) countsOut := make([]int, consumerN)
if testing.Short() { if testing.Short() {
tickT = time.Microsecond * 50
max = 1000 max = 1000
t.SkipNow()
} }
ctx := context.Background()
ctx := context.Background()
pq := NewXORDistancePQ(u.Key("11140beec7b5ea3f0fdbc95d0dd47f3c5bc275da8a31")) pq := NewXORDistancePQ(u.Key("11140beec7b5ea3f0fdbc95d0dd47f3c5bc275da8a31"))
cq := NewChanQueue(ctx, pq) cq := NewChanQueue(ctx, pq)
wg := sync.WaitGroup{} wg := sync.WaitGroup{}
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论