chapter4 review

Author: xushiwei

.gitignore

@@ -0,0 +1,2 @@
+a.out
+

chapter4/channel.go

@@ -1,16 +1,19 @@
 package main
+
 import "fmt"
+
 func Count(ch chan int) {
-    ch <- 1
-    fmt.Println("Counting")
+	fmt.Println("Counting")
+	ch <- 1
 }
+
 func main() {
-chs := make([]chan int, 10) 
-for i := 0; i < 10; i++ {
-        chs[i] = make(chan int)
-        go Count(chs[i])
-    }
-	for _, ch := range(chs) { 
-		<- ch
-	} 
-}
+	chs := make([]chan int, 10)
+	for i := 0; i < 10; i++ {
+		chs[i] = make(chan int)
+		go Count(chs[i])
+	}
+	for _, ch := range chs {
+		<-ch
+	}
+}

chapter4/goroutine.go

@@ -1,11 +1,14 @@
 package main
+
 import "fmt"
+
 func Add(x, y int) {
 	z := x + y
-    fmt.Println(z)
+	fmt.Println(z)
 }
+
 func main() {
-    for i := 0; i < 10; i++ {
-		go Add(i, i) 
+	for i := 0; i < 10; i++ {
+		go Add(i, i)
 	}
-}
+}

chapter4/goroutine2.go

@@ -1,26 +1,30 @@
 package main
+
 import "fmt"
 import "sync"
 import "runtime"
+
 var counter int = 0
+
 func Count(lock *sync.Mutex) {
-         lock.Lock()
-         counter++
-         fmt.Println(counter)  //fmt.Println(z)
-         lock.Unlock()
+	lock.Lock()
+	counter++
+	fmt.Println(counter) //fmt.Println(z)
+	lock.Unlock()
 }
+
 func main() {
-    lock := &sync.Mutex{}
-    for i := 0; i < 10; i++ {
-        go Count(lock)
+	lock := &sync.Mutex{}
+	for i := 0; i < 10; i++ {
+		go Count(lock)
 	}
-    for {
-        lock.Lock()
-        c := counter
-        lock.Unlock()
-        runtime.Gosched()
-        if c >= 10 {
-			break 
+	for {
+		lock.Lock()
+		c := counter
+		lock.Unlock()
+		runtime.Gosched()
+		if c >= 10 {
+			break
 		}
 	}
-}
+}

chapter4/thread.c

@@ -0,0 +1,40 @@
+#include <stdio.h>
+#include <stdlib.h>
+#include <pthread.h>
+
+void *count();
+pthread_mutex_t mutex1 = PTHREAD_MUTEX_INITIALIZER;
+int  counter = 0;
+
+main()
+{
+	int rc1, rc2;
+    pthread_t thread1, thread2;
+
+	/* 创建线程，每个线程独立执行函数functionC */
+
+	if((rc1 = pthread_create(&thread1, NULL, &count, NULL)))
+    {
+        printf("Thread creation failed: %d\n", rc1);
+    }
+
+	if((rc2 = pthread_create(&thread2, NULL, &count, NULL)))
+    {
+        printf("Thread creation failed: %d\n", rc2);
+    }
+
+	/* 等待所有线程执行完毕 */
+    pthread_join( thread1, NULL);
+    pthread_join( thread2, NULL);
+
+    exit(0);
+}
+
+void *count()
+{
+    pthread_mutex_lock( &mutex1 );
+    counter++;
+    printf("Counter value: %d\n",counter);
+    pthread_mutex_unlock( &mutex1 );
+}
+

env.sh

@@ -1,4 +1,3 @@
-export GOPATH=$GOPATH:$QINIUROOT/gobook/chapter1/calcproj
-export GOPATH=$GOPATH:$QINIUROOT/gobook/chapter2/sorter
-export PATH=$PATH:$QINIUROOT/gobook/chapter1/calcproj/bin
-export PATH=$PATH:$QINIUROOT/gobook/chapter2/sorter/bin
+export GOPATH=$GOPATH:$GOBOOK/chapter1/calcproj:$GOBOOK/chapter2/sorter
+export PATH=$PATH:$GOBOOK/chapter1/calcproj/bin:$GOBOOK/chapter2/sorter/bin
+