Вопросы по теме 'plinq'
Макс задач в TPL?
Я хочу использовать TPL в рабочем процессе в Windows Azure. Я хочу добавить IJob в очередь, у нее есть метод Run, поэтому рабочий будет состоять из:
цикл получения элемента из очереди Используйте TPL для вызова IJob.Run, это асинхронный вызов...
2785 просмотров
schedule
21.02.2022
Оператор Plinq заблокирован внутри статического конструктора
Я столкнулся с этой ситуацией, когда следующий оператор plinq внутри статического конструктора заблокирован:
static void Main(string[] args)
{
new Blah();
}
class Blah
{
static Blah()
{
Enumerable.Range(1, 10000)...
577 просмотров
schedule
22.03.2024
AsParallel() и размер внутреннего буфера
Как ограничить количество элементов, которые AsParallel() считывает заранее и помещает во внутренний буфер?
Вот пример:
int returnedCounter;
IEnumerable<int> Enum()
{
while (true)
yield return Interlocked.Increment(ref...
741 просмотров
schedule
14.12.2022
Как правильно распараллелить работу, сильно полагаясь на ввод-вывод
Я создаю консольное приложение, которое должно обрабатывать кучу данных.
По сути, приложение захватывает ссылки из БД. Для каждой ссылки проанализируйте содержимое файла и внесите некоторые изменения. Файлы представляют собой файлы HTML, и...
10491 просмотров
schedule
29.02.2024
никаких улучшений в следующем коде PLINQ
Я не вижу никаких улучшений в скорости обработки при использовании следующего кода:
IEnumerable<Quote> sortedQuotes = (from x in unsortedQuotes.AsParallel()
orderby (x.DateTimeTicks)...
244 просмотров
schedule
15.04.2022
Выход IEnumerable PLINQ
У меня есть функция, которая возвращает IEnumerable, которая перебирает объекты в Inbox через MAPI, но она относительно медленная, поэтому я собираюсь создать пул соединений и использовать их в многопоточном режиме. Можно ли использовать PLINQ в...
392 просмотров
schedule
21.07.2023
Как использовать PLINQ для обработки кусков массива
Мне нужно взять большой массив двойников и обработать его по частям, используя функцию, интенсивно использующую процессор.
Мой исходный массив чрезвычайно велик, около 200 МБ двойных данных сигнала.
Мне нужно взять его кусками по 5000 двойников...
770 просмотров
schedule
19.07.2022
Plinq, ядра и WithDegreeOfParallelism?
Насколько я понял, Plinq решает, сколько потоков открыть (каждый в потоке на своем ядре) по количеству ядер.
__________
Core 1
Core 2
Core 3
Core 4
___________
Итак, если у меня есть задача Plinq, которая находит все первые 1000...
3209 просмотров
schedule
09.04.2022
PLINQ Custom Partitioner, позволяющий перебирать большие диапазоны
Мне нужна помощь в создании пользовательского разделителя для PLINQ, который позволит мне перебирать IEnumerable с длиной больше, чем Int32.
Это относится к этому вопросу, где мне был дан ответ: написать собственный разделитель:
запрос PLINQ,...
356 просмотров
schedule
23.05.2023
Балансировка ядра ParallelQuery
У меня есть 200 000 задач, которые будут выполняться параллельно для увеличения скорости. Я использую ParallelEnumerable.Range(0, 200000).Sum( a => /*do_something*/ ) .
по мере того, как счетчик задач увеличивается от 0 до 200 000, необходимое...
67 просмотров
schedule
12.09.2023
Отслеживание прогресса при использовании Parallel.ForEach TPL
Как лучше всего отслеживать прогресс в следующем
long total = Products.LongCount();
long current = 0;
double Progress = 0.0;
Parallel.ForEach(Products, product =>
{
try
{
var price = GetPrice(SystemAccount, product);...
11105 просмотров
schedule
17.09.2022
Как получить отложенную загрузку с помощью PLINQ?
Одна из приятных особенностей linq заключалась в том, что бесконечные источники данных лениво обрабатывались по запросу. Я попытался распараллелить свои запросы и обнаружил, что ленивая загрузка не работает. Например...
class Program
{...
319 просмотров
schedule
05.04.2024
Отправка нескольких сообщений в операцию WCF с использованием plinq (многопоточность)
Я не совсем уверен, как прокси-класс WCF будет обрабатывать отправку запросов через plinq. Следующий фрагмент кода выглядит нормально или может вызвать проблемы с общим состоянием в нескольких потоках? (также я уже понимаю, что использование блока...
326 просмотров
schedule
11.06.2022
Существует ли асинхронная версия PLINQ?
Я хочу выполнить запрос над потоком данных при параллельной обработке элементов с определенной степенью параллелизма. Обычно я бы использовал для этого PLINQ, но мои рабочие элементы привязаны не к процессору, а к вводу-выводу. Я хочу использовать...
1108 просмотров
schedule
04.12.2023
PLINQ и логические процессоры
Конфигурация моей системы следующая: Процессор Intel(R) Core(TM) i7-3820QM @ 2,70 ГГц, 2694 МГц, 4 ядра, 8 логических процессоров
Вы можете заметить, что моя машина имеет 4 ядра и 8 логических процессоров.
Если я собираюсь использовать запрос...
70 просмотров
schedule
11.11.2022
Связывание исходного потока в PLINQ
У меня есть вычисление, которое я распараллеливаю с помощью PLINQ следующим образом:
Источник IEnumerable<T> source предоставляет объекты, прочитанные из файла.
У меня есть тяжелые вычисления HeavyComputation , которые мне нужно...
241 просмотров
schedule
01.04.2024
Проблема параллельной виртуальной машины Hyper-V PLINQ
У меня есть запрос PLINQ как таковой...
batch
.AsParallel()
.WithExecutionMode(ParallelExecutionMode.ForceParallelism)
.WithCancellation(cancellationToken);
.Select(i => new { instruction = i, accountKey = new AccountKey(i.x, i.y, i.z) })...
107 просмотров
schedule
10.10.2022
Как инициализировать большой массив параллельно с PLINQ?
Я пытаюсь инициализировать простой (но большой) массив с помощью PLINQ:
void Test(int width, int height)
{
var foo = new Foo[width * height];
foo.AsParallel().ForAll(c => new Foo());
}
Но это оставит меня с массивом нулевых...
295 просмотров
schedule
28.07.2023
параллельный linq: AsParallel().forAll() обнуляет некоторые объекты
Итак, у меня возникла очень странная ситуация, когда кажется, что plinq-запрос forAll() удаляет некоторые из моих пользовательских объектов, и, честно говоря, я понятия не имею, почему.
var myArticles =...
1471 просмотров
schedule
27.11.2022
plinq в больших списках занимает огромное время
У меня есть два списка воспроизведения и потребителей в памяти, один из которых имеет 15 миллионов объектов, а другой - около 3 миллионов.
Ниже приведены несколько запросов, которые я запускаю.
consumersn=consumers.AsParallel()...
175 просмотров
schedule
01.05.2023
