0

Имеется приложение WPF, служит для дозирования жидкостей. При каждом новом дозировании необходимо проверить, сменилась ли емкость под дозатором, и если нет, то вывести сообщение о необходимости смены емкости. Есть такой код

    public bool CheckChangeCupInThread()
    {
        if (_dispenser.Status.CupChanged == DispenserEnums.CupChanged.False)
        {
            var cupFormThread = new ThreadStart(CupWaitChangeForm);
            var cupFormWaiter = new Thread(cupFormThread) {IsBackground = true};
            cupFormWaiter.SetApartmentState(ApartmentState.STA);

            var cupThread = new ThreadStart(WaitForCupChange);
            var cupWaiter = new Thread(cupThread) {IsBackground = true};
            cupWaiter.SetApartmentState(ApartmentState.STA);

            cupFormWaiter.Start();
            cupWaiter.Start();

            do
            {
                //Wait for Cup to be changed or Cancel
            } while (cupFormWaiter.IsAlive && cupWaiter.IsAlive);

            var watch = new Stopwatch();
            watch.Start();

            if (cupFormWaiter.IsAlive)
            {
                cupFormWaiter.Abort();
                cupFormWaiter.Join();
            }
            if (cupWaiter.IsAlive)
            {
                _dispenser.SurveillanceWorker.Continue = false;
                cupWaiter.Join(200);
                return false;
            }
            watch.Stop();
        }
        return true;
    }

    private void WaitForCupChange()
    {
        do
        {
            _dispenser.GetStatus();
        } while (_dispenser.Status.CupChanged == DispenserEnums.CupChanged.False);
    }

    private void CupWaitChangeForm()
    {
        MessageBox.Show("Change please the cup", "Cup сhange", MessageBoxButtons.Cancel);
    }

здесь _dispenser собственно и есть дозатор. Принцип такой: или емкость сменили, или клавишу "Отмена" в MessageBox нажали, потоки завершаются с соответствующим результатом. Все вроде нормально на первый взгляд. Но очень часто этот код приводит к аварийному завершению работы программы. Пробовал сделать тоже самое с тасками, но как-то не очень получилось, в многопоточных приложениях я новичок. Работаю с WPF и паттерном MVVM.

9
  • А вопрос в чём? 7 фев 2017 в 13:30
  • Вы хотите переделать код с использованием Task? Или что?
    – Bulson
    7 фев 2017 в 14:14
  • Вопрос в том, как избавиться от вот этого аварийного завершения программы. Я не знаю, как лучше с Таском, или без. У меня проблема с тем, что программа вылетает
    – S_Schmal
    7 фев 2017 в 18:03
  • Покажите Вашу ошибку, приведённый код с виду исключений генерировать не должен, нужно разбираться. 8 фев 2017 в 9:50
  • 1
    Ну что за жесть... Зачем два потока, SetApartmentState, пустой цикл, повторная проверка на IsAlive?
    – Raider
    8 фев 2017 в 15:19

1 ответ 1

0

Нашел решение своей проблемы. Теперь MessageBox закрвыается, если заканчивается Task1, или Task1 прерывается, если нажата кнопка "Cancel" в MessageBox

internal class Program
{
    public const int WM_SYSCOMMAND = 0x0112;
    public const int SC_CLOSE = 0xF060;

    [DllImport("user32.dll")]
    public static extern int FindWindow(string lpClassName, string lpWindowName);

    [DllImport("user32.dll")]
    public static extern int SendMessage(int hWnd, uint Msg, int wParam, int lParam);

    private static void Main(string[] args)
    {
        Action<object> action = (object obj) =>
        {
            int i = 0;
            do
            {
                Thread.Sleep(500);
                i++;
            } while (i < 10);
            Console.WriteLine("t1 has been finished");
        };

        Action<object> action1 = (object obj) =>
        {
            DialogResult result = DialogResult.OK;
            do
            {
                result = MessageBox.Show("This is task2", "Task2", MessageBoxButtons.OKCancel);
            } while (result != DialogResult.Cancel);
            Console.WriteLine("t2 has been finished");
        };

        var tasks = new Task[2];
        var source1 = new CancellationTokenSource();
        var token1 = source1.Token;
        Task t1 = new Task(action, "alpha", token1);
        tasks[0] = t1;
        Task t2 = new Task(action1, "betha");
        tasks[1] = t2;

        t1.Start();
        Console.WriteLine("t1 has been launched. (Main Thread={0})",
            Thread.CurrentThread.ManagedThreadId);

        t2.Start();
        Console.WriteLine("t2 has been launched. (Main Thread={0})",
            Thread.CurrentThread.ManagedThreadId);

        try
        {
            int index = Task.WaitAny(tasks);
            if (t1.Status == TaskStatus.Running)
                source1.Cancel();
            if (t2.Status == TaskStatus.Running)
                CloseMessage();
            Console.WriteLine("Task #{0} completed first.\n", tasks[index].Id);
            Console.WriteLine("Status of all tasks:");
            foreach (var t in tasks)
                Console.WriteLine("   Task #{0}: {1}", t.Id, t.Status);
        }
        catch (AggregateException)
        {
            Console.WriteLine("An exception occurred.");
        }
        Console.ReadLine();
    }

    private static void CloseMessage()
    {
        int window = FindWindow(null, "Task2");
        if (window != 0)
            SendMessage(window, WM_SYSCOMMAND, SC_CLOSE, 0);
    }
}

Ваш ответ

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

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