go语言的协程goroutine（一）

package main
import "fmt"
import "time"
import "sync"
import "runtime"

/*
golang中一个goroutine（协程）默认占用的内存远比java、C的线程少，操作系统线程一般都有固定的栈内存，通常为2M

一个goroutine占用的内存非常小，一般为2k，多协程切换调度开销远比多线程小

*/


/*
以下代码的问题：如果主线程执行结束，不管协程是否执行完成都退出

通过sync.WaitGroup可以实现主线程等待协程执行完毕
*/

var wg sync.WaitGroup

//主线程和goroutine同时执行

func test(){
	for i:=0;i<10;i++{
		fmt.Println("test() golang")
		time.Sleep(time.Millisecond*100)
	}

	wg.Done()//协程的计数器减1
}


func main() {

	wg.Add(1) //协程的计数器加1
	go test()  //开启一个goroutine

	for i:=0;i<10;i++{
		fmt.Println("main() golang")
		time.Sleep(time.Millisecond*50)
	}

	wg.Wait()  //主线程等待协程执行完毕然后退出
	fmt.Println("main exit")


	cpuNume := runtime.NumCPU()  //获取cpu核数
	fmt.Println("cpuNume=",cpuNume)

	runtime.GOMAXPROCS(cpuNume-1) //设置使用多个cpu


}

package main
import "fmt"
import "time"
import "sync"

/*
通过sync.WaitGroup可以实现主线程等待协程执行完毕
for循环开启多个goroutine
*/

var wg sync.WaitGroup

func test(x int){
	defer wg.Done()
	for i:=0;i<5;i++{
		fmt.Printf("协程%v打印出第%v个值\n",x, i)
		time.Sleep(time.Millisecond*100)
	}
}


func main() {

   //循环开启多个goroutine
	for i:=0;i<5;i++{
		wg.Add(1) //协程的计数器加1
		go test(i)
	}

	wg.Wait()  //主线程等待协程执行完毕然后退出
	fmt.Println("main exit")

}