Method ScanFloat1AttributeParallelWithPoolSize

modeling/mesh.go:601–639

(atr string, size int, f func(i int, v float64))

}

func (m Mesh) ScanFloat1AttributeParallelWithPoolSize(atr string, size int, f func(i int, v float64)) Mesh {
	m.requireV1Attribute(atr)

	if size < 1 {
		panic(fmt.Errorf("unable to scan float1, invalid worker pool size: %d", size))
	}

	if size == 1 {
		return m.ScanFloat1Attribute(atr, f)
	}

	var wg sync.WaitGroup

	data := m.v1Data[atr]
	workSize := int(math.Floor(float64(len(data)) / float64(size)))
	for i := 0; i < size; i++ {
		wg.Add(1)

		jobSize := workSize

		// Make sure to clean up potential last cell due to rounding error of
		// division of number of CPUs
		if i == size-1 {
			jobSize = len(data) - (workSize * i)
		}

		go func(start, size int) {
			defer wg.Done()
			end := start + size
			for i := start; i < end; i++ {
				f(i, data[i])
			}
		}(workSize*i, jobSize)
	}

	wg.Wait()

	return m
}

func (m Mesh) ModifyFloat3Attribute(atr string, f func(i int, v vector3.Float64) vector3.Float64) Mesh {
	m.requireV3Attribute(atr)