1
package main

func main(){
  go func1()
  go func2()
  go func3()
  for{
  }
}

func func1(){
  for{
  }
}

func func2(){
  for{
  }
}

func func3(){
  for{
  }
}

上のような構造のコードを作成しましたが、それぞれの関数のgoroutineが動きません。このことはそれぞれのgoroutineの最初にprint文を使い確かめました。それぞれのfor文は無限ループです。また、それぞれの関数ではTwitterのStreaming APIを使って、情報を取得しています。

goのバージョンはgo version go1.4.2 linux/armです。
このような実装はできないのでしょうか、それとも、Twitter Streaming APIの影響でできなくなっているのでしょうか。

0

1 件の回答 1

1

Go1.4までは、デフォルトでCPUを1コアしか使わないようになっています。

なぜCPUを1コアしか使っていないのに複数のgoroutineを同時に実行できるのかというと、適当なタイミングで実行するgoroutineをつぎつぎに切り替えているからです。(スケジューリング)

ただし、この切り替えのタイミングは特定の操作を行った場合に限られます。
このページ(http://dominik.honnef.co/go-tip/2013-08-15/)によると、チャンネル操作・ロック・関数呼び出し、だそうです。

つまり、何もしていない無限ループに入ってしまうと、他のgoroutineに切り替えるタイミングがありません。どれか一つのgoroutine内のfor{}に到達するとそのループでCPUを占有し続けるため、他のgoroutineが実行できなくなってしまいます。

今回の場合はmain内のループで止まってしまっているのだと思います。他のgoroutineのループに先に到達すれば当然そちらで止まってしまいます。

// こういうのもダメです
for {
  i += 1
}

ループ内で「チャンネル操作・ロック・関数呼び出し」のいずれかを行うか、もしくは1コアCPUのRaspberry Piでは無理ですがGOMAXPROCSで使用するコア数を増やしてやれば解決します。

3
  • 回答ありがとうございます。1つ質問なのですが、func1などの中のfor文でselect文を使ってチャンネルから値を取得しようとすれば値が取得できなくともそれはチャンネル操作と判定され別の例えば他のfunc3などの別のgoroutineに処理が移るのでしょうか Commented 2015年10月1日 11:51
  • はい、selectでブロックする場合でも切り替えは行われます。しかし、すべてのgoroutineでブロックしてしまうと当然ながらデッドロックが発生します。
    – h2so5
    Commented 2015年10月2日 13:49
  • 2
    @zousan Golang: goroutine infinite-loop を読みますと、runtime.Gosched() を全てのループに差し込むという方法がある様です。
    – user9156
    Commented 2015年10月3日 10:41

この質問に回答するには、ログインする必要があります。

求めていた回答ではありませんか? のタグが付いた他の質問を参照する。