sliding_benchmark_test.go

package sliding_test

import (
	"sync"
	"testing"
	"time"

	"github.com/tetsuo/sliding"
	slidingv1 "github.com/tetsuo/sliding/v1"
)

func BenchmarkSlidingAtomic(b *testing.B) {
	c := sliding.NewCounter(time.Second * 10)

	for i := 0; i < b.N; i++ {
		c.Increment()
	}
}

func BenchmarkSlidingChannels(b *testing.B) {
	c := slidingv1.NewCounter(time.Second * 10)

	for i := 0; i < b.N; i++ {
		c.Inc()
	}
}

func BenchmarkSlidingConcurrentAtomic(b *testing.B) {
	if b.N == 1 {
		return
	}

	c := sliding.NewCounter(time.Second * 10)

	var wg sync.WaitGroup
	for range 4 {
		wg.Add(1)
		go func() {
			defer wg.Done()
			for i := 0; i < b.N/4; i++ {
				c.Increment()
			}
		}()
	}

	wg.Wait()
}

func BenchmarkSlidingConcurrentChannels(b *testing.B) {
	if b.N == 1 {
		return
	}

	c := slidingv1.NewCounter(time.Second * 10)

	var wg sync.WaitGroup
	for range 4 {
		wg.Add(1)
		go func() {
			defer wg.Done()
			for i := 0; i < b.N/4; i++ {
				c.Inc()
			}
		}()
	}

	wg.Wait()
}