subscription_test.go

package opcua

import (
	"testing"

	"github.com/gopcua/opcua/ua"
)

// Running tool: /Users/frank/sdk/go1.17.1/bin/go test -benchmem -run=^$ -bench ^BenchmarkUnmonitorItems$ github.com/gopcua/opcua

// goos: darwin
// goarch: arm64
// pkg: github.com/gopcua/opcua
// BenchmarkUnmonitorItems/slice-8         	51153620	        24.03 ns/op	      20 B/op	       0 allocs/op
// --- BENCH: BenchmarkUnmonitorItems/slice-8
//     subscription_test.go:29: src 1 dst 0
//     subscription_test.go:29: src 100 dst 50
//     subscription_test.go:29: src 10000 dst 5000
//     subscription_test.go:29: src 1000000 dst 500000
//     subscription_test.go:29: src 51153620 dst 25576810
// BenchmarkUnmonitorItems/slice_pre-alloc-8         	91635986	        22.77 ns/op	       8 B/op	       0 allocs/op
// --- BENCH: BenchmarkUnmonitorItems/slice_pre-alloc-8
//     subscription_test.go:51: src 1 dst 0
//     subscription_test.go:51: src 100 dst 50
//     subscription_test.go:51: src 10000 dst 5000
//     subscription_test.go:51: src 1000000 dst 500000
//     subscription_test.go:51: src 91635986 dst 45817993
// BenchmarkUnmonitorItems/map-8                     	39885550	        43.72 ns/op	       0 B/op	       0 allocs/op
// --- BENCH: BenchmarkUnmonitorItems/map-8
//     subscription_test.go:75: src 0
//     subscription_test.go:75: src 50
//     subscription_test.go:75: src 5000
//     subscription_test.go:75: src 500000
//     subscription_test.go:75: src 19942775
// PASS
// ok  	github.com/gopcua/opcua	116.192s

func BenchmarkUnmonitorItems(b *testing.B) {
	b.Run("slice", func(b *testing.B) {
		src := make([]*monitoredItem, b.N)
		for i := 0; i < b.N; i++ {
			src[i] = &monitoredItem{
				res: &ua.MonitoredItemCreateResult{
					MonitoredItemID: uint32(i),
				},
			}
		}

		b.ResetTimer()
		var dst []*monitoredItem
		for _, item := range src {
			if item.res.MonitoredItemID%2 == 0 {
				continue
			}
			dst = append(dst, item)
		}

		b.Log("src", len(src), "dst", len(dst)) // ensure src and dst are not GC'ed
	})

	b.Run("slice pre-alloc", func(b *testing.B) {
		src := make([]*monitoredItem, b.N)
		for i := 0; i < b.N; i++ {
			src[i] = &monitoredItem{
				res: &ua.MonitoredItemCreateResult{
					MonitoredItemID: uint32(i),
				},
			}
		}

		b.ResetTimer()
		dst := make([]*monitoredItem, 0, len(src))
		for _, item := range src {
			if item.res.MonitoredItemID%2 == 0 {
				continue
			}
			dst = append(dst, item)
		}

		b.Log("src", len(src), "dst", len(dst)) // ensure src and dst are not GC'ed
	})

	b.Run("map", func(b *testing.B) {
		idsToDelete := []uint32{}
		src := make(map[uint32]*monitoredItem, b.N)
		for i := 0; i < b.N; i++ {
			id := uint32(i)
			src[id] = &monitoredItem{
				res: &ua.MonitoredItemCreateResult{
					MonitoredItemID: id,
				},
			}

			if id%2 == 0 {
				idsToDelete = append(idsToDelete, id)
			}
		}

		b.ResetTimer()
		for _, id := range idsToDelete {
			delete(src, id)
		}

		b.Log("src", len(src)) // ensure src and dst are not GC'ed
	})
}