Различных нити сродство в Parallel.For Итерациях

Question

мне нужна итерация параллельного цикла для использования 7 ядер (или остаться в стороне от 1 ядра), но другая итерация использовать 8 (все) ядра и попытался код ниже:

Parallel.For(0,2,i=>{ 
    if(i=0) 
    Process.GetCurrentProcess().ProcessorAffinity = (System.IntPtr)(255); 

    if(i==1) 
    Process.GetCurrentProcess().ProcessorAffinity = (System.IntPtr)(254); 
    Thread.Sleep(25);// to make sure both set their affinities 
    Console.WriteLine(Process.GetCurrentProcess().ProcessorAffinity); 
}); 

Это выводит 255 для обеих итераций. Таким образом, либо цикл parallel.for использует для них один поток, либо один параметр устанавливает итеративность других итераций. Еще одна проблема заключается в том, что это приложение, чувствительное к задержкам, и все эти настройки сродства добавляют задержку от 1 до 15 миллисекунд.

Должен ли я использовать потоки в явном виде и должен ли я устанавливать атрибуты только один раз?

Редактировать: Я пробовал резьбовую версию, то же самое происходит. Даже с явным двумя потоками, как для записи 255 на консоль. Теперь кажется, что эта команда предназначена для процесса, а не для потока.

Контекст OpenCL использует максимальные ядра для выполнения ядра на процессоре на одной итерации. Другие итерации с использованием 1-2 ядер для копирования буферов и отправки команды на устройства. Когда cpu используется opencl, он использует все ядра, и устройства не могут получить достаточно времени для копирования буферов. Деление устройства кажется сложнее, чем решить эту проблему, которую я считаю.

Answer 1

другой поток сродством в Parallel.For Итерации

Вопрос вводит в заблуждение, так как он основан на предположении, что Parallel API означает несколько потоков. Parallel API ссылается на параллельную обработку данных, но не предоставляет никаких гарантий для вызова multiple threads, особенно для приведенного выше кода, где практически нет работы на поток.

Для Parallel API, вы можете установить максимальную степень параллельности следующим образом:

ParallelOptions parallelOption = new ParallelOptions(); 

parallelOption.MaxDegreeOfParallelism = Environment.ProcessorCount; 

Parallel.For(0, 20, parallelOption, i => 

Но это не гарантирует количество потоков, которые будут вызываться в параллельной обработке, так как Нитки используются из ThreadPool и CLR решает во время выполнения, исходя из количества обрабатываемой работы, требуется ли больше one thread для обработки.

В этом же цикле Parallel вы можете попробовать следующее, напечатать Thread.Current.ManageThreadId, это обеспечит четкую идею относительно количества потоков, вызываемых в цикле Parallel.

Должен ли я использовать потоки в явном виде и должен ли я устанавливать аффинности только один раз?

Редактировать: Я пробовал резьбовую версию, то же самое происходит. Даже с явным двумя потоками, как для записи 255 на консоль. Теперь кажется, что эта команда предназначена для процесса, а не для потока.

Можете ли вы разместить код для нескольких потоков, можете ли вы попробовать что-то вроде этого.

Thread[] threadArray = new Thread[2]; 
threadArray[0] = new Thread(<ThreadDelegate>); 
threadArray[1] = new Thread(<ThreadDelegate>); 
threadArray[0]. ProcessorAffinity = <Set Processor Affinity> 
threadArray[1]. ProcessorAffinity = <Set Processor Affinity> 

Предполагая, что вы назначаете сродство правильно, вы можете напечатать их и найти различные значения, проверьте следующее ProcessThread.ProcessorAffinity.

На другой заметке, как вы могли видеть по ссылке выше, вы можете установить значение в hexadecimal на основе близости процессора, не уверен, что означает значения 254, 255, действительно ли у вас есть сервер с таким количеством процессоров.

EDIT:

Попробуйте следующее редактировать в программу, (на основании того, что два Идентификаторы темы становятся напечатанными), теперь к тому времени оба потока некоторые в картине, они оба получают одинаковое значение из variable i, они нуждаются в local variable, чтобы избежать закрытия Issue

Parallel.For(0,2,i=>{ 
    int local = i; 
    if(local=0) 
    Process.GetCurrentProcess().ProcessorAffinity = (System.IntPtr)(255); 

    if(local==1) 
    Process.GetCurrentProcess().ProcessorAffinity = (System.IntPtr)(254); 
    Thread.Sleep(25);// to make sure both set their affinities 
    Console.WriteLine(Process.GetCurrentProcess().ProcessorAffinity); 
}); 

EDIT 2: (в основном бы не работать, как оба потока может увеличиваться, до фактического выполнения логики)

int local = -1; 
    Parallel.For(0,2,i=>{ 
    Interlocked.Increment(ref local); 
    if(local=0) 
    Process.GetCurrentProcess().ProcessorAffinity = (System.IntPtr)(255); 

    if(local==1) 
    Process.GetCurrentProcess().ProcessorAffinity = (System.IntPtr)(254); 
    Thread.Sleep(25);// to make sure both set their affinities 
    Console.WriteLine(Process.GetCurrentProcess().ProcessorAffinity); 
});