goloutineまたはmultithreadingがgolangで動作しない

Question

私はgolangでマルチスレッドを実装しようとしていました。私はgoルーチンを実装することができますが、期待どおりに動作していません。以下、私が用意したサンプルプログラム、

func test(s string, fo *os.File) { 
    var s1 [105]int 
    count :=0 
    for x :=1000; x<1101;x++ { 
    s1[count] = x; 
     count++ 
    } 

    //fmt.Println(s1[0]) 
    for i := range s1 { 
     runtime.Gosched() 
     sd := s + strconv.Itoa(i) 
     var fileMutex sync.Mutex 
     fileMutex.Lock() 
     fmt.Fprintf(fo,sd) 
     defer fileMutex.Unlock() 
    } 
} 

func main() { 
    fo,err :=os.Create("D:/Output.txt") 
    if err != nil { 
     panic(err) 
    } 
    for i := 0; i < 4; i++ { 
     go test("bye",fo) 

    } 



} 

OUTPUTある - good0bye0bye0bye0bye0good1bye1bye1bye1bye1good2bye2bye2bye2bye2 ....など 上記のプログラムは、ファイルに「BYE」ファイルを作成して書き込み、「こんにちは」となります。

私の問題は5スレッドを作成しようとしていて、別のスレッドで異なる値の値を処理したかったのです。上記の例が表示される場合は、「bye」を4回印刷しています。

iは、など....

任意のアイデアどのように私はこれを達成することができます.... 5スレッド、

good0bye0good1bye1good2bye2を使用して、以下のような出力をしたいですか？

Answer 1

まず、他のすべてのゴルーチンが戻るまでメイン関数をブロックする必要があります。あなたのプログラムのmutexesは何もをブロックしていないし、各ループで再初期化されているので、自分のゴルーチン内でブロックさえしない。関数から戻ってこない場合は、ロック解除を延期することはできません。ループの各反復で明示的にロックを解除する必要があります。配列の値は使用していません（代わりにスライスを使用する必要があります）ので、その値を完全に削除することができます。うまく動作するプログラムにruntime.GoSchedは必要なく、ここでは何もしません。

完了まで実行されます同等のプログラムは次のようになります。

var wg sync.WaitGroup 

var fileMutex sync.Mutex 

func test(s string, fo *os.File) { 
    defer wg.Done() 
    for i := 0; i < 105; i++ { 
     fileMutex.Lock() 
     fmt.Fprintf(fo, "%s%d", s, i) 
     fileMutex.Unlock() 
    } 
} 

func main() { 
    fo, err := os.Create("D:/output.txt") 
    if err != nil { 
     log.Fatal(err) 
    } 
    for i := 0; i < 4; i++ { 
     wg.Add(1) 
     go test("bye", fo) 

    } 
    wg.Wait() 
} 

は最後にかかわらず、複数のゴルーチンから単一のファイルにシリアル値を試してみて、書き込みする理由はありません、それはそうするために非効率的です。値全体をファイル全体に並べ替えるには、とにかく単一のゴルーチンを使用する必要があります。