002 goroute同時ベース

1104 ワード

package main

import (
	"fmt"
	"time"
)

func test_goroute(i int)  {
	if i % 10 == 0 {
		fmt.Println()
	}
	fmt.Print(i," ")
}

func main() {
	for i := 0; i<100; i++ {
		go test_goroute(i)
	}
	time.Sleep(10 * time.Second)  // , 
}

出力は
20 22 23 12 5 14 2 31 16 32 18 19 8 21 37 0 1 24 25 26 27 28 44 
30 17 
50 35 36 
10 54 
56 57 43 59 45 46 47 48 49 33 15 51 34 52 53 39 38 55 40 41 42 58 29 
60 62 63 61 65 64 
70 66 67 68 69 77 71 72 73 74 75 76 84 78 79 81 
80 91 85 86 87 88 89 
90 95 92 93 94 97 96 98 83 82 99 

実現は簡単だよね?
Goはgo文を使用して新しいランタイムスレッドを開くことを許可します
gorouteは軽量レベルのスレッド(ただしスレッドではない)と理解でき、サーバのマルチ起動は停止しません.
channelパイプ(先進先出キュー)、unix/linuxのpipeのように、複数のgorouteがパイプ内のデータを取得して通信する
上の2つはCSPモデル(communicating sequential process通信シーケンスプロセス)を構成する
 
例:
package main

import (
        "fmt"
)

func fibonacci(n int, c chan int) {
        x, y := 0, 1
        for i := 0; i < n; i++ {
                c 

【チャネル:https://www.runoob.com/go/go-concurrent.html】