fixedprocess_test.go

package parallel

import (
	"math"
	"testing"
)

// MARK: Tests

func TestFixedProcessCompleteness_01(t *testing.T) {
	v := make([]float64, 1000000)
	p := NewFixedProcess(1)
	p.Execute(len(v), func(i int) {
		v[i] = float64(i + 1)
	})

	for i, value := range v {
		if float64(i+1) != value {
			t.Errorf("Value, %f, should be equal to %f.", value, float64(i+1))
			break
		}
	}
}

func TestFixedProcessCompleteness_02(t *testing.T) {
	v := make([]float64, 1000000)
	p := NewFixedProcess(2)
	p.Execute(len(v), func(i int) {
		v[i] = float64(i + 1)
	})

	for i, value := range v {
		if float64(i+1) != value {
			t.Errorf("Value, %f, should be equal to %f.", value, float64(i+1))
			break
		}
	}
}

func TestStopFixedProcess(t *testing.T) {
	v := make([]float64, 1000000)
	p := NewFixedProcess(2)
	p.Execute(len(v), func(i int) {
		if i == len(v)/2 {
			p.Stop()
		}

		v[i] = float64(i + 1)
	})

	for i, value := range v {
		if i <= len(v)/2 {
			if float64(i+1) != value {
				t.Errorf("Value, %f, should be equal to %f.", value, float64(i+1))
				break
			}
		} else {
			if value != 0.0 {
				t.Errorf("Value, %f, should be equal to 0.0.", value)
				break
			}
		}
	}
}

// MARK: Benchmarks

func BenchmarkFixedProcess_01(b *testing.B) {
	v := make([]float64, 1000000)
	p := NewFixedProcess(1)

	for n := 0; n < b.N; n++ {
		p.Execute(len(v), func(i int) {
			v[i] = math.Sqrt(float64(i))
		})
	}
}

func BenchmarkFixedProcess_02(b *testing.B) {
	v := make([]float64, 1000000)
	p := NewFixedProcess(2)

	for n := 0; n < b.N; n++ {
		p.Execute(len(v), func(i int) {
			v[i] = math.Sqrt(float64(i))
		})
	}
}