5
class test
{
   public List<Thread> threads = new List<Thread>();
    public int nThreads = 0;
    public int maxThreads = 5;

    public void DoWork(object data)
    {
        string message = (string)data;
        //MessageBox.Show(message);        


    }

    public void CreateThread(object data)
    {
        if (nThreads >= maxThreads)
            return;
        Thread newThread = new Thread(DoWork);
        threads.Add(newThread);
        newThread.IsBackground = true;
        newThread.Start(data);
        nThreads++;


    }

    public void WindUpThreads()
    {
        //MessageBox.Show("count: " + nThreads.ToString());
        for(int i = 0; i < threads.Count; i++)
        {
            if (threads[i].IsAlive == false)
            {
                threads[i].Abort();
                threads.RemoveAt(i);
               //MessageBox.Show("removing at " + i.ToString());
            }

        }

        nThreads = threads.Count;
    }

}

Мне нужно в методе DoWork изменять данные в listbox, но я не хочу привязывать логику к элементам управления. Как лучше поступить в таком случае?

В общем я решил пойти самым простым путем и передал делегат в тред:

   public delegate void TestDeleg(string message);
public class Data
{
    public TestDeleg deleg;
    public string mess;
    }

public void DoWork(object data)
{
    Data d = (Data)data;
    d.deleg(d.mess);
    //string message = (string)data;
    //MessageBox.Show(d.mess);      
    return;


}

В цикле теперь передаю класс с запакованным данными:

Data d = new Data();
d.deleg = AddItem;
d.mess = strings[counter];
thTest.CreateThread((object)d);

Ну и сам метод, который добавляет строку в листбокс:

public void AddItem(string message)
{

    //listBox1.Items.Add(message);
    if(InvokeRequired)
        listBox1.Invoke( (Action)( () => { listBox1.Items.Add(message); } ) );
    else
        listBox1.Items.Add(message);

}

Теперь почему-то цикл никогда не заканчивается и треды не завершаются, метод, который должен очищать треды почему-то не срабатывает.

UPD: Кажется, причина, по которой интерфейс не обновлялся, выяснилась. Основная часть моей программы была такой:

while (flag == true)
{
    if (counter >= dataCount)
    {
        flag = false;
    }

    while (thTest.nThreads < thTest.maxThreads)
    {
        if (flag == false)
            break;

        thTest.CreateThread(strings[counter]);

        counter++;
    }

    thTest.WindUpThreads();

    if (flag == false)
    {
        do
        {
            thTest.WindUpThreads();

        } while (thTest.nThreads != 0);
    }

}

И запускался этот код по нажатию на кнопку. Получается, что цикл крутился в основном потоке и поэтому ui не принимал сообщения об изменении. Когда я вынес уже этот код в отдельный поток (получается один поток создает другие и управляет ими), то все стало на свои места.

10
  • Если вы не хотите привязывать логику к элементам управления, пользуйтесь MVVM и обновляйте в фоне вью-модель.
    – VladD
    Commented 7 янв. 2016 в 15:20
  • listBox1.Invoke( (Action)( () => { listBox1.Items.Add(message); } ) ); -- так у вас не те данные могут оказаться в listbox. чтобы такого не было, в listBox1.Invoke надо передать делегат на AddItem и message. посмотрите мой ответ ниже.
    – Stack
    Commented 7 янв. 2016 в 16:52
  • Я что-то не совсем догнал. У меня получается что AddItem описан в классе формы, я его передаю в DoWork и там вызываю. Почему там могут оказаться не те данные? И как я передам в listBox1.Invoke делегат на Additem, если я invoke в этом Additem вызываю - получится рекурсия какая-то. Commented 7 янв. 2016 в 17:08
  • @АлександрПушкин "Почему там могут оказаться не те данные?" -- почитайте про 'сюрприз' с замыканиями тут
    – Stack
    Commented 7 янв. 2016 в 17:26
  • @АлександрПушкин "если я invoke в этом Additem вызываю - получится рекурсия какая-то" -- нет. посмотрите мой ответ. я его дополнил про "рекурсию".
    – Stack
    Commented 7 янв. 2016 в 17:32

4 ответа 4

3

Нужно вашу логику отделить от представления. Представить ваше "сердце" приложения как некоторую штуку, которая принимает "команды" из UI и отправляет информацию об изменении состояния - "события". В главном потоке слушать события UI и отправлять в "сердце" соответствующие им команды; подписаться на события основной логики и в соответствий с происходящим перерисовывать ваш UI.

Посмотрите на IObservable и Reactive Extensions.

И общие замечания - не рекомендуется создавать потоки руками. Поток - это достаточно тяжелая сущность. Многопоточность реализуется через различные библиотеки, где примитивы несколько интереснее и более удобные, чем потоки. Куда смотреть - Rx, Task Parrallel Library; читать - Jeffrey Richter, CLR via C# последнюю редакцию, главу про многопоточность.

4
  • Тогда получается, что мне нужно подписываться на событие в каждом созданном треде? А если тредов будет много, не слишком ли это нагрузит систему? И нужно ли от них отписываться, если я собираюсь удалить тред? Commented 7 янв. 2016 в 15:47
  • Подписаться только в основном потоке, в котором обновляется UI. В нём же слушать события контролов и формировать из них команды. О потокобезопасности "сердца" - это отдельный разговор. Опять же - непонятно откуда у вас будет "много тредов", и что такое - "слишком много". Рекомендую прочитать главу Рихтера про многопоточное программирование (там же про async/await). Commented 7 янв. 2016 в 15:48
  • Получается мне нужно полностью логику менять? Потому что в основном потоке я не могу подписаться на событие в конкретном треде в текущей версии кода. Commented 7 янв. 2016 в 15:51
  • Я понял, хорошо, спасибо. Commented 7 янв. 2016 в 15:59
0
  • Завести класс, хранящий состояние DoWork для отображения.
  • Передать в DoWork делегат или объект presenter, который будет отображать состояние на listbox (используя BeginInvoke)
  • Вызывать периодически presenter из под DoWork
4
  • А можно ли в DoWork передать делегат, который объявлен в форме, задача которого изменять данные на форме? Commented 7 янв. 2016 в 15:27
  • @АлександрПушкин Можно, если обернуть его вызов в BeginInvoke или Invoke
    – Serj-Tm
    Commented 7 янв. 2016 в 15:35
  • не подскажете как это сделать? Тред ведь только объект принимает, а преобразовать делегат в объект это наркомания какая-то. Commented 7 янв. 2016 в 15:39
  • @АлександрПушкин Передать в DoWork свой объект или Tuple, где одно из полей будет делегат.
    – Serj-Tm
    Commented 7 янв. 2016 в 15:49
0

Как вариант, вы можете в потоках класть данные для ListBox в какую-нибудь коллекцию из System.Collections.Concurrent, а в основном (GUI) треде брать оттуда элементы и пихать их в целевой ListBox.

Лично я предпочел бы использовать ConcurrentQueue<T> следующим образом:

  1. В потоках добавляем элементы.
  2. В GUI-треде по таймеру забираем и очищаем.
1
  • Да, в принципе можно, но по-моему это очень серьезный подход. Вроде как можно это через события реализовать, только во-первых не совсем понятно как это сделать, а во-вторых, не будет ли это слишком ресурсозатратно. Commented 7 янв. 2016 в 15:20
0

Мне нужно в методе DoWork изменять данные в listbox

Если метод DoWork вызывается из разных потоков, то это можно проверить и данные передать в UI-поток, примерно так:

public void DoWork(object data) {
  if (listbox.InvokeRequired)
    listbox.BeginInvoke(new Action<object>(DoWork), data);
  else
    listbox.Items.Add((string)data);
}

На первый взгляд выглядит как рекурсия, но это не рекурсия, т.к. метод BeginInvoke ставит вызов делегата в очередь, элементы которой обрабатывается в UI-потоке.
Другой пример передачи в UI-поток данных из разных потоков тут.


Если надо отделить модель/данные от UI, то пример тут и тут.

2
  • Да, но это уже привязывание логики к интерфейсу, хотелось бы этого избежать. Commented 7 янв. 2016 в 15:49
  • "привязывание логики к интерфейсу, хотелось бы этого избежать" -- добавил в ответ ссылку на пример.
    – Stack
    Commented 7 янв. 2016 в 15:53

Ваш ответ

Нажимая «Отправить ответ», вы соглашаетесь с условиями пользования и подтверждаете, что прочитали политику конфиденциальности.

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