Форум программистов, компьютерный форум, киберфорум
C# .NET
Войти
Регистрация
Восстановить пароль
Блоги Сообщество Поиск Заказать работу  
 
Рейтинг 4.88/8: Рейтинг темы: голосов - 8, средняя оценка - 4.88
12 / 12 / 1
Регистрация: 18.06.2011
Сообщений: 434

Pause и Resume в Parallel.Foreach

20.08.2015, 10:17. Показов 1615. Ответов 1
Метки нет (Все метки)

Author24 — интернет-сервис помощи студентам
Сделал пробный проект, в котором идет просто вывод переменной из List<int>. При нажатии на кнопку Button2 переменной isPaused приравнивается true. Таким образом проект приостанавливает свою работу. Возникли два вопроса
  • Если я делаю количество потоков 4 то разброс данных различается, и я не знаю с какого момента продолжить выполнение цикла. Если бы все шло по порядку я бы мог удалить данные из list вплоть до значения переменной lowestBreakIndex и снова запустить метод StartProcess
  • Есть ли более кошерное решение данной задачи?


C# Скопировано
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
public bool isPaused;
public long lowestBreakIndex;
public List<int> list = new List<int>();
 
 
private void button1_Click(object sender, EventArgs e)
{
    for (int i = 0; i < 10000; i++)
        list.Add(i);
    Thread th = new Thread(StartProcess);
    th.Start();
 
}
 
private void StartProcess()
{
 
    isPaused = IsTerminated = false;
    isProcessing = true;
 
    ParallelLoopResult result = Parallel.ForEach(list, new ParallelOptions() { MaxDegreeOfParallelism = 1 },
        (item, state) =>
        {
            Thread.Sleep(1000);
            //I swapped these two.
            if (isPaused)
            {
                textBox1.Invoke((MethodInvoker)delegate {
                    textBox1.Text += "Пауза";
                    textBox1.Text += Environment.NewLine;
                });
                state.Break();
            }
            else if (IsTerminated)
            {
                textBox1.Invoke((MethodInvoker)delegate {
                    textBox1.Text += "Терминатор";
                    textBox1.Text += Environment.NewLine;
                });
 
            }
            else
            {
                if (textBox1.InvokeRequired)
 
                {
 
                    textBox1.Invoke((MethodInvoker)delegate {
 
                        textBox1.Text += item;
                        textBox1.Text += Environment.NewLine;
                    });
 
                }
 
            }
 
        });
    var lowestBreakIndex = result.LowestBreakIteration;
}
 
private void button2_Click(object sender, EventArgs e)
{
    isPaused = true;
}
0
Programming
Эксперт
39485 / 9562 / 3019
Регистрация: 12.04.2006
Сообщений: 41,671
Блог
20.08.2015, 10:17
Ответы с готовыми решениями:

Распараллеливание. Parallel.ForEach
На данный момент выполняется такой код: Hashtable files2copy; void startButton_Click(object sender, RoutedEventArgs e) { ...

PLINQ или Parallel.ForEach?
Пытаюсь сообразить как лучше сделать задачку. Есть большой список EXCEL файлов и мне надо их считать проделать некоторые операции (все...

Parallel.ForEach эффективное использование
Хотелось бы услышать реальный опыт использования параллельных циклов и плюсы от использования, если они есть. Как я понимаю такие циклы...

1
Эксперт .NET
 Аватар для insite2012
5546 / 4309 / 1218
Регистрация: 12.10.2013
Сообщений: 12,371
Записей в блоге: 2
20.08.2015, 14:37
Цитата Сообщение от Radzhab Посмотреть сообщение
Таким образом проект приостанавливает свою работу.
Использовать булевскую переменную для приостановки потоков не очень хороший способ. Используйте WaitHandl-ы.
0
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
inter-admin
Эксперт
29715 / 6470 / 2152
Регистрация: 06.03.2009
Сообщений: 28,500
Блог
20.08.2015, 14:37
Помогаю со студенческими работами здесь

Parallel.Foreach изменение коллекции
Если коллекция Dictionary&lt;string,Class&gt; dic; Первый поток добавляет и удаляет элементы из коллекции используя Parallel.Foreach Второй...

Parallel.ForEach что не верно? Не компилируется
class Program { static void Main(string args) { ParallelOptions parOpt = new ParallelOptions(); ...

Parallel.ForEach и его неадекватное поведение
Задача простая. Я выполняю какие либо действия, в результате чего у меня появляется допустим огромный массив с данными, которые мне нужно...

Сравнение списков Parallel.ForEach неадекватный результат
Сравниваю два списка, возвращаю первое совпадение. Но возвращаемое значение всегда разное при одинаковых списках. В чем может заключаться...

Parallel foreach ожидание для каждого потока
Добрый день. Есть Parallel.ForEach, который внутри себя вызывает json запрос на сервер. Parallel.ForEach(arr, v =&gt; { ...


Искать еще темы с ответами

Или воспользуйтесь поиском по форуму:
2
Ответ Создать тему
Новые блоги и статьи
Агрегаты и сущности в DDD микросервисах
Javaican 10.04.2025
Разработка современных программных систем часто приводит на распутье: монолит или микросервисы? Даже при выборе микросервисной архитектуры многие команды сталкиваются с проблемой правильного. . .
Многопоточность в C#: Task и параллельное программирование
UnmanagedCoder 10.04.2025
Современные процессоры уже давно перестали наращивать тактовую частоту в пользу увеличения количества ядер. Это создало интересную ситуацию: разработчики, привыкшие к последовательному. . .
Линейное решение нелинейной задачи будет применено как метод обработки данных из double buffering. Формулы от LM конечно с ошибками.
Hrethgir 10.04.2025
В продолжение Эта LM дала ответ похожий на нормальный. В комментриях мой комментарий - похоже она ошиблась с выведением итоговой формулы, но остальные проверю. Assistant qwen2. 5-14b-instruct . . . .
Переменные в Python
py-thonny 10.04.2025
Переменная в программировании — это символическое имя, связанное с областью памяти, в которой хранится значение. Она позволяет получать доступ к данным через понятные человеку идентификаторы, а не. . .
Многопоточность в C#: Task и асинхронные операции
UnmanagedCoder 10.04.2025
Многопоточность позволяет выполнять несколько операций одновременно, что важно для решения двух основных задач: повышения скорости выполнения вычислительно-сложных операций и сохранения отзывчивости. . .
Линейное решение не линейной задачи (емкость вычислений в сравнении с традиционными решениями пока не определена).
Hrethgir 10.04.2025
В рамках предстоящих вычислений пришлось (да, я тоже знаю про корень числа, и про степеня, и прочие теоремы, но. . . ) найти способ нахождения отношения двух углов. . . .
Запуск контейнеров Docker на ARM64
Mr. Docker 09.04.2025
Появление таких решений, как Apple M1/ M2, AWS Graviton, Ampere Altra и Raspberry Pi, сделало использование ARM-систем обыденностью для многих разработчиков и DevOps-инженеров. При этом Docker,. . .
Vue SFC компонент на PHP с Fusion
Jason-Webb 09.04.2025
PHP на сервере и JavaScript на клиенте — классическое сочетание, которое, несмотря на свою эффективность, создает определенный когнитивный диссонанс при разработке. В этом контексте появляются. . .
TypeScript vs JavaScript: Отличия и когда что использовать
Reangularity 09.04.2025
JavaScript появился в 1995 году как творение Брендана Эйха и быстро стал основой интерактивности в вебе. За свою историю он прошел путь от простого языка для манипуляций с DOM до полноценной. . .
Подключение Kafka к Elasticsearch
Codd 09.04.2025
Apache Kafka и Elasticsearch — две мощные технологии, которые при совместном использовании создают эффективную платформу для обработки и анализа данных в реальном времени. Kafka, выступая в роли. . .
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2025, CyberForum.ru
Выделить код Копировать код Сохранить код Нормальный размер Увеличенный размер