C# と VB.NET の質問掲示板

■No60310 (ＫＱ さん) に返信

各処理の区別をするためのクラス(実際にはなくてもよい)
public class NumAction
{
	public int No;
	public Action Act;
}


private void button1_Click(object sender, EventArgs e)
{
行う処理を１０ほど追加（実際の処理をここでQueueに追加）
	Queue<NumAction> TaskQue = new Queue<NumAction>();
	for (int i = 0; i < 10; i++) {
		TaskQue.Enqueue(new NumAction {No =i,Act = () => {
			System.Threading.Thread.Sleep(500);
		}});
	}
並列処理部の処理
	List<Action> ActList = new List<Action>();
	Action act = () =>
	{
		NumAction Tsk;
		do
		{
			lock (TaskQue)
			{
				Tsk = null;
				if (TaskQue.Count > 0)
				{
					Tsk = TaskQue.Dequeue();
				}
			}
			if (Tsk != null)
			{
				Console.WriteLine("Begin:" + Tsk.No);
				Tsk.Act();
				Console.WriteLine("End:" + Tsk.No);
		}
		} while (Tsk != null);
	};
３つ並列なので３つ追加
	ActList.Add(act);
	ActList.Add(act);
	ActList.Add(act);
並列実行
	Parallel.ForEach(ActList,  act2 => act2());
}

■No60515 (shu さん) に返信
> ■No60514 (ＫＱ さん) に返信
> 
>>「３つ並列」で起動した後、計算処理が終了する前に、
>>次々と残りの計算を実行しはじめてしまいます。
> 各計算処理が別スレッドで動くような作りになっていませんか？
> 各計算処理はスレッド起動をしないで動作する作りにしておいて下さい。
> スレッドセーフな作りにはしておいて下さい。

実行用のクラスは、以下のようにしました。
public class NumAction
{
	public int No;
        public Action Act;
        public long CalcNum; // 計算exeに渡す数値
}

実行コードの中で、
----------------------------------------------
Queue<NumAction> TaskQue = new Queue<NumAction>();

// 計算数(作成した計算リストの数)
int total = CalcList.CalcDataList.Count;

// 行う処理を追加
for (int i = 0; i < total; i++)
{
	int idx = i;
        TaskQue.Enqueue(new NumAction
        {
           No = i,
           Act = () =>
           {
	      // プロセス起動
              StartProcess(idx);
           }
         }
         );
         }
......
----------------------------------------------
private void StartProcess(int idx)
{        
	// 渡す数値
        long num = CalcList.CalcDataList[idx].Num;

        Process process = new Process();
        process.StartInfo.FileName = ExeFileName;
        process.StartInfo.WindowStyle = ProcessWindowStyle.Normal;
        process.StartInfo.WorkingDirectory = Path.GetDirectoryName(exePath);
        process.StartInfo.Arguments = string.Format("{0}", num);

        process.Start();
}
で、Processのインスタンスを作成して、計算exeを起動しています。

Processのインスタンスで起動するのは、スレッドセーフではないのかも…？？