0

В общем есть цикл, в нём что-то параллельно делается, и при определённых условиях нужно его остановить, и что-то на форме занести в текстбоксы, после чего программа считывает эти текстбоксы.
Нашёл что-то про ManualResetEventSlim, но он блочит все потоки, и с формой не поработаешь (висит). Наколхозил в таком виде (в том месте, где нужно остановить):

    ManualResetEventSlim mres.Reset();
    if(MainProcID == Thread.CurrentThread.ManagedThreadId) //MainProcID получаю при
    // инициализации формы
    {
      while (!CF) //булевый флаг для бесконечного цикла, пока кнопку не 
      //нажму
      {
        Application.DoEvents();
      }
      //тут что-нибудь делаю
      mres.set();
    }
    else
    mres.Wait();

Но как это покрасивее сделать? Тут ещё, полагаю, будут проблемы, если 2 потока решат её остановить - непредсказуемый результат - надо ещё флагами защищаться. Ну, соответственно - потом надо запустить по нажатию кнопки.

Весь цикл

Parallel.ForEach(DRList, new ParallelOptions { MaxDegreeOfParallelism = 5 }, DR =>
        {
            ClassSrz srz1 = new ClassSrz("SRZ-01", DBSelected);
            i++;
            //reportProgress(i * 100 / Col);



            int C = srz1.ExecuteNonQueryR("update ZAGS_PARENT_INFO set PID=" + DR["ID"].ToString() +
                  " where DR=" + strToSQL(DR["DR"].ToString(), date: true, last: true) +
                  " and docn=" + strToSQL(DR["DOCN"].ToString(), last: true) +
                  " and DOCS=" + strToSQL(DR["DOCS"].ToString(), last: true) +
                  " and docdt=" + strToSQL(DR["DOCDT"].ToString(), date: true, last: true) +
                  " and FAM_NEW=" + strToSQL(DR["FAM"].ToString(), last: true) +
                  " and IM_NEW=" + strToSQL(DR["IM"].ToString(), last: true) +
                  " and OT_NEW=" + strToSQL(DR["OT"].ToString(), last: true) +
                  " and PID is null"

                   );
            int CWNew = srz1.ExecuteNonQueryR("update ZAGS_BRAK_INFO set PID_W_NEW=" + DR["ID"].ToString() +
                " where DR_W=" + strToSQL(DR["DR"].ToString(), date: true, last: true) +
                " and docn_W=" + strToSQL(DR["DOCN"].ToString(), last: true) +
                " and DOCS_W=" + strToSQL(DR["DOCS"].ToString(), last: true) +
                " and docdt_W=" + strToSQL(DR["DOCDT"].ToString(), date: true, last: true) +
                " and FAM_W_NEW=" + strToSQL(DR["FAM"].ToString(), last: true) +
                " and IM_W=" + strToSQL(DR["IM"].ToString(), last: true) +
                " and OT_W=" + strToSQL(DR["OT"].ToString(), last: true) +
                " and PID_W_NEW is null"

                 );
            int CMNew = srz1.ExecuteNonQueryR("update ZAGS_BRAK_INFO set PID_M_NEW=" + DR["ID"].ToString() +
                " where DR_M=" + strToSQL(DR["DR"].ToString(), date: true, last: true) +
                " and docn_M=" + strToSQL(DR["DOCN"].ToString(), last: true) +
                " and DOCS_M=" + strToSQL(DR["DOCS"].ToString(), last: true) +
                " and docdt_M=" + strToSQL(DR["DOCDT"].ToString(), date: true, last: true) +
                " and FAM_M_NEW=" + strToSQL(DR["FAM"].ToString(), last: true) +
                " and IM_M=" + strToSQL(DR["IM"].ToString(), last: true) +
                " and OT_M=" + strToSQL(DR["OT"].ToString(), last: true) +
                " and PID_M_NEW is null"


                 );

            int CMOld = srz1.ExecuteNonQueryR("update ZAGS_BRAK_INFO set PID_M_OLD=" + DR["ID"].ToString() +
            " where DR_M=" + strToSQL(DR["DR"].ToString(), date: true, last: true) +
            " and docn_M=" + strToSQL(DR["DOCN"].ToString(), last: true) +
            " and DOCS_M=" + strToSQL(DR["DOCS"].ToString(), last: true) +
            " and docdt_M=" + strToSQL(DR["DOCDT"].ToString(), date: true, last: true) +
            " and FAM_M_OLD=" + strToSQL(DR["FAM"].ToString(), last: true) +
            " and IM_M=" + strToSQL(DR["IM"].ToString(), last: true) +
            " and OT_M=" + strToSQL(DR["OT"].ToString(), last: true) +
            " and PID_M_OLD is null"


             );
            int CWOld = srz1.ExecuteNonQueryR("update ZAGS_BRAK_INFO set PID_W_OLD=" + DR["ID"].ToString() +
             " where DR_W=" + strToSQL(DR["DR"].ToString(), date: true, last: true) +
             " and docn_W=" + strToSQL(DR["DOCN"].ToString(), last: true) +
             " and DOCS_W=" + strToSQL(DR["DOCS"].ToString(), last: true) +
             " and docdt_W=" + strToSQL(DR["DOCDT"].ToString(), date: true, last: true) +
             " and FAM_W_OLD=" + strToSQL(DR["FAM"].ToString(), last: true) +
             " and IM_W=" + strToSQL(DR["IM"].ToString(), last: true) +
             " and OT_W=" + strToSQL(DR["OT"].ToString(), last: true) +
             " and PID_W_OLD is null"


              );
            if (ColPar == 1)
            {
                mres.Reset();
                if (MainProcID == Thread.CurrentThread.ManagedThreadId)
                {
                    CF = false;
                    while (!CF)
                    {
                        Application.DoEvents();
                    }
                }
                else
                    mres.Wait();
            }
            BeginInvoke((Action)(() =>
            {
                pB1.Value = i; ColPar += C; ColBracWNew += CWNew; ColBracMNew += CMNew;
                ColBracWOld += CWOld; ColBracMOld += CMOld;
                //Останавливаем для выбора

            }));
            Application.DoEvents();
            //   Thread.Sleep(100);                             
        }
        );

Вот кнопка

 private void ChangeFlag_Click(object sender, EventArgs e)
    {
        CF = true;
        if (mres.IsSet)
            mres.Reset();
        else
            mres.Set();
    }

P.S. условие if (ColPar == 1) просто для теста поставил пока

7
  • А где вашParallel.ForEach()? Покажите весь код.
    – Bulson
    30 окт 2019 в 7:50
  • Это было внутри него, добавил весь цикл и кнопку в вопрос 30 окт 2019 в 8:43
  • Судя по описанному, вызов Parallel.ForEach происходит в гуевом потоке. Запускайте его в отдельном потоке (таске). Тогда можно будет убрать вызов Application.DoEvents. 30 окт 2019 в 9:33
  • 1
    Покажите определение CF - volatile имеется? / И ради всего святого, используйте параметры в sql-запросах. 30 окт 2019 в 9:35
  • Если поместите Parallel.ForEach в отдельный поток, то основной перестанет виснуть. Соответственно, станет не нужным Application.DoEvents и, вероятно, цикл while тоже будет не нужен. А стало быть, и переменная CF не нужна. Но логика кода такая, что сложновато въехать... 30 окт 2019 в 12:55

1 ответ 1

0

пример работы

public partial class MainForm : Form
{
    //источник токена отмены
    private CancellationTokenSource _cts;

    public MainForm()
    {
        InitializeComponent();

        StartPosition = FormStartPosition.CenterScreen;
        Text = "Пример";

        _buttonCancel.Click += ButtonCancel_Click;
        _buttonStart.Click += ButtonStart_Click;
    }

    private async void ButtonStart_Click(object sender, EventArgs e)
    {
        //готовим запуск
        _textBoxOutput.Text = String.Empty;
        _buttonCancel.Enabled = true;
        _buttonStart.Enabled = false;
        //собираем данные
        var inputs = new string[] { _textBoxFirst.Text, _textBoxSecond.Text, _textBoxThird.Text };
        //новый источник токена отмены
        _cts = new CancellationTokenSource();
        //опции для параллельного запуска
        var po = new ParallelOptions();
        //передаем токен отмены
        po.CancellationToken = _cts.Token;

        try
        {
            //запускаем задачей чтоб освободить UI
            await Task.Run(() => RunParallel(inputs, po));
        }
        finally
        {
            //настраиваем по окончании вычисления
            _buttonCancel.Enabled = false;
            _buttonStart.Enabled = true;
            _cts.Dispose();
        }
    }

    private void ButtonCancel_Click(object sender, EventArgs e)
    {
        //отправляем запрос на отмену
        _cts.Cancel();
    }

    private void RunParallel(string[] inputs, ParallelOptions po)
    {
        try
        {
            Parallel.ForEach(inputs, po, (string t, ParallelLoopState state) =>
            {
                //если был запрос на отмену, останавливаем цикл
                if (po.CancellationToken.IsCancellationRequested)
                {
                    state.Stop();
                }

                //получаем данные
                var text = GetText(t, po.CancellationToken) + Environment.NewLine;
                //отображаем данные
                this.BeginInvoke((Action)(() => _textBoxOutput.Text += text));
            });
        }
        catch (Exception ex)
        {
            this.BeginInvoke((Action)(() => _textBoxOutput.Text += ex.Message));
        }
    }

    //метод, который типа что-то вычисляет
    private string GetText(string t, CancellationToken cancellationToken)
    {
        var result = String.Empty;
        for (int i = 0; i < 5; i++)
        {
            //бросаем исключение в случае отмены
            cancellationToken.ThrowIfCancellationRequested();

            Thread.Sleep(500);
            result += $"{t}[{i}]";
        }
        return result;
    }
}
2
  • А разве в этом po.CancellationToken.IsCancellationRequested есть какой-то смысл если дальше мы вызываем cancellationToken.ThrowIfCancellationRequested() ?
    – iluxa1810
    31 окт 2019 в 7:38
  • @iluxa1810 Может и нет, я лишь хотел показать, что есть ParallelLoopState state а у него Stop()
    – Bulson
    31 окт 2019 в 7:41

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.