1

お世話になります。
C#のtaskで、合計10個のtaskをRunさせたいと思っているのですが、
デバッグするとtaskが4、5個は走るのですが、残りが走らずにwaiting状態となってしまいます。
内容として、同一のメソッドを一つのインスタンスを用いて繰り返し走らせようとしています。
スレッドプールの上限や下限を見ても問題はないはずなのですが、
理由や解決策が見つからない状態です。
よろしくお願いします。

以下に簡潔なソースを書かせて頂きます

// 10個スレッドを生成する箇所
TaskWork taskWork = new TaskWork();
 for (int i = 0; i < 10; i++) {
    Task.Run(() => taskWork.Work());
}

// task処理するクラスメソッド
public class TaskWork
{
  public void Work() {
    while(true) {
      // taskで繰り返す処理
    }
  }
}
2
  • 同じ事象が再現できるような、最小化されたコードはご呈示いただけませんか?
    – OOPer
    Commented 2017年3月13日 5:09
  • コメントにある程度の長さのコードを入れるのは面倒な上に、読みにくくなります。ご自身の質問は「編集」可能かと思いますので、コードをご提示いただけるならご質問を編集して追記してくださるようお願いします。
    – OOPer
    Commented 2017年3月13日 5:15

2 件の回答 2

5

Taskは結果を得るための一連の処理を表す概念です。例えばStream.ReadAsync()はread結果を得るためのタスクを返します。そしてTaskの実行方法については規定されておらず、.NETランタイムが効率が良いと考える方法で実行されます。
その際、基本的にはTaskは短時間で完了すると仮定し、不用意に多数のTaskを並列実行しません。もし、長時間実行するTaskなのであれば作成時にTaskCreationOptions.LongRunningを指定することでランタイムにTaskの性質を通知すべきです。

コードが提示されたので

// 10個スレッドを生成する箇所
TaskWork taskWork = new TaskWork();
for (int i = 0; i < 10; i++) {
    //Task.Run(() => taskWork.Work());
    Task.Factory.StartNew(() => taskWork.Work(), TaskCreationOptions.LongRunning);
}

としてはどうでしょうか。

ただし、そもそもTaskの概念を理解しておらず、ThreadもしくはThreadPoolの代替として選択されているのであれば、Taskではなく適切なクラスを使用することをお勧めします。

1
  • ありがとうございます。Threadとtaskの認識が混在していました。整理してみます。
    – petton
    Commented 2017年3月14日 5:17
3

タスクで実行している内容に問題があります。

端的に言えばCPUコア数と同じ4タスクを開始した時点でCPUを100%使ってしまい、他の処理が行われる余地が非常に少ないためにタスクの起動が非常に遅くなっています。(まったく実行されないわけではありません)

ですのでTaskWork.Workの中で他のスレッドに実行機会を譲るためにThread.Sleepを指定してやる必要があります。

while (true)
{
    // taskで繰り返す処理
    Thread.Sleep(1000); // 1秒間スリープする
}

スリープ時間はミリ秒で指定します。出来るだけCPU時間を譲りたくない場合は0とすると必要時のみスリープが行われます。

1
  • ありがとうございます。sleepを入れたところ少しずつ同時実行されていきました。
    – petton
    Commented 2017年3月14日 5:18

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

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