How to use runParallel method of internal Package

1// Copyright 2020 The Go Authors. All rights reserved.2// Use of this source code is governed by a BSD-style3// license that can be found in the LICENSE file.4// This package contains microbenchmarks exercising specific areas of interest.5// The benchmarks here are not comprehensive and are not necessarily indicative6// real-world performance.7package micro_test8import (9	"testing"10	"google.golang.org/protobuf/internal/impl"11	"google.golang.org/protobuf/proto"12	"google.golang.org/protobuf/runtime/protoiface"13	"google.golang.org/protobuf/types/known/emptypb"14	micropb "google.golang.org/protobuf/internal/testprotos/benchmarks/micro"15	testpb "google.golang.org/protobuf/internal/testprotos/test"16)17// BenchmarkEmptyMessage tests a google.protobuf.Empty.18//19// It measures per-operation overhead.20func BenchmarkEmptyMessage(b *testing.B) {21	b.Run("Wire/Marshal", func(b *testing.B) {22		b.RunParallel(func(pb *testing.PB) {23			m := &emptypb.Empty{}24			for pb.Next() {25				if _, err := proto.Marshal(m); err != nil {26					b.Fatal(err)27				}28			}29		})30	})31	b.Run("Wire/Unmarshal", func(b *testing.B) {32		opts := proto.UnmarshalOptions{33			Merge: true,34		}35		b.RunParallel(func(pb *testing.PB) {36			m := &emptypb.Empty{}37			for pb.Next() {38				if err := opts.Unmarshal([]byte{}, m); err != nil {39					b.Fatal(err)40				}41			}42		})43	})44	b.Run("Wire/Validate", func(b *testing.B) {45		b.RunParallel(func(pb *testing.PB) {46			mt := (&emptypb.Empty{}).ProtoReflect().Type()47			for pb.Next() {48				_, got := impl.Validate(mt, protoiface.UnmarshalInput{})49				want := impl.ValidationValid50				if got != want {51					b.Fatalf("Validate = %v, want %v", got, want)52				}53			}54		})55	})56	b.Run("Clone", func(b *testing.B) {57		b.RunParallel(func(pb *testing.PB) {58			m := &emptypb.Empty{}59			for pb.Next() {60				proto.Clone(m)61			}62		})63	})64}65// BenchmarkRepeatedInt32 tests a message containing 500 non-packed repeated int32s.66//67// For unmarshal operations, it measures the cost of the field decode loop, since each68// item in the repeated field has an individual tag and value.69func BenchmarkRepeatedInt32(b *testing.B) {70	m := &testpb.TestAllTypes{}71	for i := int32(0); i < 500; i++ {72		m.RepeatedInt32 = append(m.RepeatedInt32, i)73	}74	w, err := proto.Marshal(m)75	if err != nil {76		b.Fatal(err)77	}78	b.Run("Wire/Marshal", func(b *testing.B) {79		b.RunParallel(func(pb *testing.PB) {80			for pb.Next() {81				if _, err := proto.Marshal(m); err != nil {82					b.Fatal(err)83				}84			}85		})86	})87	b.Run("Wire/Unmarshal", func(b *testing.B) {88		opts := proto.UnmarshalOptions{89			Merge: true,90		}91		b.RunParallel(func(pb *testing.PB) {92			m := &testpb.TestAllTypes{}93			for pb.Next() {94				m.RepeatedInt32 = m.RepeatedInt32[:0]95				if err := opts.Unmarshal(w, m); err != nil {96					b.Fatal(err)97				}98			}99		})100	})101	b.Run("Wire/Validate", func(b *testing.B) {102		b.RunParallel(func(pb *testing.PB) {103			mt := (&testpb.TestAllTypes{}).ProtoReflect().Type()104			for pb.Next() {105				_, got := impl.Validate(mt, protoiface.UnmarshalInput{106					Buf: w,107				})108				want := impl.ValidationValid109				if got != want {110					b.Fatalf("Validate = %v, want %v", got, want)111				}112			}113		})114	})115	b.Run("Clone", func(b *testing.B) {116		b.RunParallel(func(pb *testing.PB) {117			for pb.Next() {118				proto.Clone(m)119			}120		})121	})122}123// BenchmarkRequired tests a message containing a required field.124func BenchmarkRequired(b *testing.B) {125	m := &micropb.SixteenRequired{126		F1:  proto.Int32(1),127		F2:  proto.Int32(1),128		F3:  proto.Int32(1),129		F4:  proto.Int32(1),130		F5:  proto.Int32(1),131		F6:  proto.Int32(1),132		F7:  proto.Int32(1),133		F8:  proto.Int32(1),134		F9:  proto.Int32(1),135		F10: proto.Int32(1),136		F11: proto.Int32(1),137		F12: proto.Int32(1),138		F13: proto.Int32(1),139		F14: proto.Int32(1),140		F15: proto.Int32(1),141		F16: proto.Int32(1),142	}143	w, err := proto.Marshal(m)144	if err != nil {145		b.Fatal(err)146	}147	b.Run("Wire/Marshal", func(b *testing.B) {148		b.RunParallel(func(pb *testing.PB) {149			for pb.Next() {150				if _, err := proto.Marshal(m); err != nil {151					b.Fatal(err)152				}153			}154		})155	})156	b.Run("Wire/Unmarshal", func(b *testing.B) {157		opts := proto.UnmarshalOptions{158			Merge: true,159		}160		b.RunParallel(func(pb *testing.PB) {161			m := &micropb.SixteenRequired{}162			for pb.Next() {163				if err := opts.Unmarshal(w, m); err != nil {164					b.Fatal(err)165				}166			}167		})168	})169	b.Run("Wire/Validate", func(b *testing.B) {170		b.RunParallel(func(pb *testing.PB) {171			mt := (&micropb.SixteenRequired{}).ProtoReflect().Type()172			for pb.Next() {173				_, got := impl.Validate(mt, protoiface.UnmarshalInput{174					Buf: w,175				})176				want := impl.ValidationValid177				if got != want {178					b.Fatalf("Validate = %v, want %v", got, want)179				}180			}181		})182	})183	b.Run("Clone", func(b *testing.B) {184		b.RunParallel(func(pb *testing.PB) {185			for pb.Next() {186				proto.Clone(m)187			}188		})189	})190}...

1import (2func main() {3	parallel.RunParallel()4	fmt.Println("I am done")5}6import (7func main() {8	parallel.RunParallel()9	fmt.Println("I am done")10}

1import "fmt"2func main() {3    fmt.Println("Hello, playground")4    r := runParallel{}5    r.runParallel(5)6}7import "fmt"8type runParallel struct {}9func (r *runParallel) runParallel(i int) {10    fmt.Println("Hello, playground")11}

1import (2func main() {3	fmt.Println("main")4	var p = new(Parallel)5	p.runParallel()6}