added channel parallel benchmark
This commit is contained in:
		| @@ -20,6 +20,21 @@ func BenchmarkGenerateChan(b *testing.B) { | |||||||
|  |  | ||||||
| } | } | ||||||
|  |  | ||||||
|  | // Benchmarks Presence Update event with fake data. | ||||||
|  | func BenchmarkGenerateChanParallel(b *testing.B) { | ||||||
|  |  | ||||||
|  | 	node, _ := NewFlakeNode(1) | ||||||
|  | 	c := make(chan Flake) | ||||||
|  | 	go node.Generator(c) | ||||||
|  |  | ||||||
|  | 	b.ReportAllocs() | ||||||
|  | 	b.RunParallel(func(pb *testing.PB) { | ||||||
|  | 		for pb.Next() { | ||||||
|  | 			<-c | ||||||
|  | 		} | ||||||
|  | 	}) | ||||||
|  | } | ||||||
|  |  | ||||||
| // Benchmarks Presence Update event with fake data. | // Benchmarks Presence Update event with fake data. | ||||||
| func BenchmarkGenerate(b *testing.B) { | func BenchmarkGenerate(b *testing.B) { | ||||||
|  |  | ||||||
|   | |||||||
		Reference in New Issue
	
	Block a user