mirror of
https://github.com/chrislusf/seaweedfs
synced 2024-05-19 18:01:03 +02:00
26 lines
334 B
Go
26 lines
334 B
Go
package util
|
|
|
|
import "testing"
|
|
|
|
func TestEnqueueAndConsume(t *testing.T) {
|
|
|
|
q := NewUnboundedQueue()
|
|
|
|
q.EnQueue("1", "2", "3")
|
|
|
|
f := func(items []string) {
|
|
for _, t := range items {
|
|
println(t)
|
|
}
|
|
println("-----------------------")
|
|
}
|
|
q.Consume(f)
|
|
|
|
q.Consume(f)
|
|
|
|
q.EnQueue("4", "5")
|
|
q.EnQueue("6", "7")
|
|
q.Consume(f)
|
|
|
|
}
|