3

そのようなコードがあります。

スレッドの開始:

Thread[] thr;
static object locker = new object();
bool liking = true;
private void button2_Click(object sender, EventArgs e)
{
    button2.Enabled = false;
    button3.Enabled = true;
    string post = create_note();

    decimal value = Program.Data.numericUpDown1;
    int i = 0;
    int j = (int)(value);
    thr = new Thread[j];
    for (; i < j; i++)
    {
        thr[i] = new Thread(() => invite(post)); 
        thr[i].IsBackground = true;
        thr[i].Start();
    }

}
public void invite(string post)
{
    while (liking)
    {
        if (//some comdition)
            exit all threads, and start string post = create_note(); again
    }
}

何らかの条件が満たされた場合invite(string post)は、すべてのスレッドを停止し、string post = create_note();もう一度行って文字列ポストを取得し、スレッドを再開する必要があります。

どうやってするの？

4

2 に答える 2

3

手動のスレッド管理の代わりに、次のように使用Parallel.ForしCancellationTokenます。

        var cts = new CancellationTokenSource();
        var options = new ParallelOptions 
        { 
            CancellationToken = cts.Token,
            MaxDegreeOfParallelism = System.Environment.ProcessorCount
        };
        var result = Parallel.For(0, j, options, i =>
        {
            invite(post);
            options.CancellationToken.ThrowIfCancellationRequested();
        });

並列計算をキャンセルしたい場合はcts.Cancel()、外部コードから呼び出すだけです。

于 2013-07-28T10:55:29.667 に答える
0

lock を使用して、そのようなスレッドを管理するクラスを作成できます。

public class SyncClass
{
    public Thread[] thr;
    private int NumberOfWorkingThreads { get; set; }
    private object Sync = new object();

    public int ThreadNumber { get; private set; }

    public event EventHandler TasksFinished;

    public SyncClass(int threadNumber)
    {
        thr = new Thread[threadNumber];
        ThreadNumber = threadNumber;
        NumberOfWorkingThreads = ThreadNumber;
        //LunchThreads(threadNumber);
    }

    protected void OnTasksFinished()
    {
        if (TasksFinished == null)
            return;
        lock (Sync)
        {
            NumberOfWorkingThreads--;
            if (NumberOfWorkingThreads == 0)
                TasksFinished(this, new EventArgs());
        }
    }

    public void LunchThreads()
    {
        string post = create_note();
        for (int i = 0; i < ThreadNumber; i++)
        {
            thr[i] = new Thread(() => invite(post));
            thr[i].IsBackground = true;                
            thr[i].Start();
        }
    }

    private void invite(string post)
    {
        while (true)
        {
            if (true)
            {
                break;
            }
        }
        OnTasksFinished();
    }


}

イベントを使用してすべてのスレッドの終了を通知すると、クラスは次のように使用されます。

    private void Operation()
    {
        var sync = new SyncClass(10);
        sync.TasksFinished += sync_TasksFinished;
        sync.LunchThreads();
    }



     void sync_TasksFinished(object sender, EventArgs e)
    {
        Operation();
    }
于 2013-07-28T11:19:37.383 に答える