Upgrade to go 1.22 and use 1.22 syntax

Author: markdingo

.github/workflows/codecov.yml

@@ -7,7 +7,7 @@ jobs:
     strategy:
       matrix:
         os: [ ubuntu-latest, macos-latest, windows-latest ]
-        go: [ 1.21.x ]
+        go: [ 1.22.x ]
     runs-on: ${{ matrix.os }}
     steps:
     - uses: actions/checkout@main

.github/workflows/go.yml

@@ -7,7 +7,7 @@ jobs:
     name: Build and Test
     strategy:
       matrix:
-        go: [ 1.21.x ]
+        go: [ 1.22.x ]
     runs-on:
       - ubuntu-latest
     steps:

_examples/demo1.go

@@ -38,7 +38,7 @@ type runner struct {
 
 func (rnr *runner) run(stdout, stderr io.Writer) {
 	total := 0
-	for count := 0; count < rnr.howMany; count++ {
+	for count := range rnr.howMany {
 		fmt.Fprintf(os.Stderr, "id:%d Write #%d for %d\n", rnr.id, count, len(rnr.line))
 		n, _ := stdout.Write([]byte(rnr.line))
 		total += n

_examples/nested.go

@@ -97,7 +97,7 @@ func recurs(prefix string, depth, widthIndex int, stdout, stderr io.Writer) {
 
 	grp, _ := parallel.NewGroup(parallel.OrderRunners(opts.keepOrder),
 		parallel.WithStdout(stdout), parallel.WithStderr(stderr))
-	for ix := 0; ix < opts.width; ix++ {
+	for ix := range opts.width {
 		ix := ix // Pre 1.22 semantics
 		grp.Add("", "", func(out, err io.Writer) {
 			recurs(prefix, depth+1, ix, out, err)

go.mod

@@ -1,3 +1,3 @@
 module github.com/markdingo/parallel
 
-go 1.20
+go 1.22

group_test.go

@@ -266,7 +266,7 @@ type testMemoryRunner struct {
 
 func (tqr *testMemoryRunner) run(stdout, stderr io.Writer) {
 	<-tqr.start
-	for tqrCount := 0; tqrCount < tqr.howMany; tqrCount++ {
+	for range tqr.howMany {
 		n, _ := stdout.Write([]byte(tqr.line))
 		testTBWritten.Add(int32(n))
 	}
@@ -320,7 +320,7 @@ func TestGroupLimitMemoryPerRunner(t *testing.T) {
 	// reaching memory limits.
 	firstTB := tb
 	lastTB := tb
-	for ix := 0; ix < 10; ix++ {
+	for range 10 {
 		time.Sleep(time.Millisecond * 100)
 		tb = int(testTBWritten.Load())
 		if tb == lastTB {

tagger.go

@@ -54,7 +54,7 @@ func (wtr *tagger) Write(p []byte) (n int, err error) {
 	defer wtr.mu.Unlock()
 
 	lines := bytes.Split(p, nl)
-	for ix := 0; ix < len(lines)-1; ix++ { // Process allbut the last line
+	for ix := range len(lines) - 1 { // Process allbut the last line
 		if wtr.tagPending {
 			_, e := wtr.out.Write(wtr.tag) // W2: Bytes not returned for tag
 			if e != nil && err == nil {    // but first error is always returned