format code

Author: steevehook

atomics/atomic-implementation/atomic_amd64.s

@@ -1,4 +1,4 @@
-TEXT ·StoreInt64(SB), $0-16
+TEXT ·StoreInt64(SB),$0-16
     MOVQ	ptr+0(FP), BX
     MOVQ	val+8(FP), AX
     XCHGQ	AX, 0(BX)

atomics/atomic-implementation/main.go

@@ -25,7 +25,7 @@ func main() {
 	var wg sync.WaitGroup
 
 	wg.Add(100)
-	for i:=0;i<100;i++ {
+	for i := 0; i < 100; i++ {
 		go func(i int) {
 			defer wg.Done()
 			StoreInt64(&count, int64(i+1))

atomics/race/main.go

@@ -13,11 +13,11 @@ func main() {
 	wg.Add(5)
 	go func() {
 		defer wg.Done()
-		count+=10
+		count += 10
 	}()
 	go func() {
 		defer wg.Done()
-		count-=15
+		count -= 15
 	}()
 	go func() {
 		defer wg.Done()

go-routines/io/main.go

@@ -38,5 +38,5 @@ func main() {
 	wg.Wait()
 
 	// wait for one more Tracing event
-	time.Sleep(2*time.Second)
+	time.Sleep(2 * time.Second)
 }

gomaxprocs/gomaxprocs-many-threads/main.go

@@ -12,7 +12,8 @@ func main() {
 	runtime.GOMAXPROCS(32)
 	for i := 0; i < 32; i++ {
 		go func() {
-			for{}
+			for {
+			}
 		}()
 	}
 	time.Sleep(time.Minute)

intro/fixed-async-tasks/main.go

@@ -21,13 +21,13 @@ func main() {
 }
 
 func task1(done chan struct{}) {
-	time.Sleep(100*time.Millisecond)
+	time.Sleep(100 * time.Millisecond)
 	fmt.Println("task1")
 	done <- struct{}{}
 }
 
 func task2(done chan struct{}) {
-	time.Sleep(200*time.Millisecond)
+	time.Sleep(200 * time.Millisecond)
 	fmt.Println("task2")
 	done <- struct{}{}
 }
@@ -38,7 +38,7 @@ func task3(done chan struct{}) {
 }
 
 func task4(done chan struct{}) {
-	time.Sleep(100*time.Millisecond)
+	time.Sleep(100 * time.Millisecond)
 	fmt.Println("task4")
 	done <- struct{}{}
 }

intro/fork-join/channel-join-point/main.go

@@ -19,6 +19,6 @@ func main() {
 }
 
 func work() {
-	time.Sleep(500*time.Millisecond)
+	time.Sleep(500 * time.Millisecond)
 	fmt.Println("printing some stuff")
 }

intro/fork-join/no-join-point/main.go

@@ -7,12 +7,12 @@ import (
 
 func main() {
 	go work() // fork point
-	time.Sleep(100*time.Millisecond)
+	time.Sleep(100 * time.Millisecond)
 	fmt.Println("done waiting, main exits")
 	// join point
 }
 
 func work() {
-	time.Sleep(500*time.Millisecond)
+	time.Sleep(500 * time.Millisecond)
 	fmt.Println("printing some stuff")
 }

intro/fork-join/wg-join-point/main.go

@@ -21,6 +21,6 @@ func main() {
 }
 
 func work() {
-	time.Sleep(500*time.Millisecond)
+	time.Sleep(500 * time.Millisecond)
 	fmt.Println("printing some stuff")
 }

waitgroups/wg-reuse/simple/main.go

@@ -4,6 +4,7 @@ import (
 	"sync"
 	"time"
 )
+
 // This is a small extras from the official docs
 // --------------------------------------------
 // Note that calls with a positive delta that occur when the counter is zero

waitgroups/with-waitgroup/main.go

@@ -13,7 +13,7 @@ func main() {
 	wg.Add(10)
 	now := time.Now()
 	for i := 0; i < 10; i++ {
-		go work(&wg, i + 1)
+		go work(&wg, i+1)
 	}
 	wg.Wait()
 	fmt.Println("elapsed:", time.Since(now))