Разбить массив элементов на приблизительно равные части

@Castello2401 · Регистрация: 06.03.2012

Author24 — интернет-сервис помощи студентам

Есть массив элементов, нужно разбить его на Environment.ProcessorCount массивов, с приблизительно равными элементами.

@tezaurismosis · 27.02.2015, 09:44

Сообщение от Castello2401

с приблизительно равными элементами

Имеется в виду "с приблизительно равным количеством элементов"?
Решение пока такое, но оно меня не совсем устраивает

C#

IEnumerable<int> array = new int[] { 10, 20, 30, 40, 50, 60, 70 };
int size = array.Count() / Environment.ProcessorCount;
var result = new List<IEnumerable<int>>(); // результат тут
int skipped = 0;
while (skipped < array.Count()) {
    result.Add(array.Take(2));
    array = array.Skip(2);
}

@kolorotur · 27.02.2015, 20:08

Сообщение от Castello2401

Есть массив элементов, нужно разбить его на Environment.ProcessorCount массивов

Судя по тому, что нужно Environment.ProcessorCount частей, могу предположить, что вы собираетесь обрабатывать массив в разных потоках, а раз это нужно всего лишь для обработки, то зачем его вообще разбивать? В каждый поток отправляйте ссылку на массив, с какого индекса начинать и сколько элементов обрабатывать. И пусть все потоки работают с одним и тем же массивом.

@Castello2401 · 27.02.2015, 21:59 **[ТС]**

Сообщение от kolorotur

могу предположить, что вы собираетесь обрабатывать массив в разных потоках

Именно.

Сообщение от kolorotur

раз это нужно всего лишь для обработки, то зачем его вообще разбивать? В каждый поток отправляйте ссылку на массив, с какого индекса начинать и сколько элементов обрабатывать

Вот так я собираюсь задействовать несколько потоков:

C#

            ParameterizedThreadStart threadStart = new ParameterizedThreadStart(data =>
                {
                    /// blablabla
                });
 
            Thread[] threads = new Thread[Environment.ProcessorCount];
 
            for (int i = 0; i < threads.Length; i++)
                threads[i] = new Thread(threadStart);
 
            foreach (var thread in threads) thread.Start(new object()); // example
            foreach (var thread in threads) thread.Join();

thread.Start принимает один аргумент типа object, по Вашему сценарию мне придется передать ему не строго типизированный массив с тремя значениями - dataArray, startIndex, dataCount, потом все это еще и распаковать придется. Дабы меньше кода было, я хочу передать потоку только массив обрабатываемых элементов.

@kolorotur · 28.02.2015, 09:31

Сообщение от Castello2401

по Вашему сценарию мне придется передать ему не строго типизированный массив с тремя значениями - dataArray, startIndex, dataCount, потом все это еще и распаковать придется.

Есть готовая структура ArraySegment, кода добавляет совсем немного:

C#

            ParameterizedThreadStart threadStart = new ParameterizedThreadStart(data =>
                {
                    var segment = (ArraySegment<int>)data;
                    foreach (var number in segment)
                       // blablabla
                });
 
            Thread[] threads = new Thread[Environment.ProcessorCount];
 
            for (int i = 0; i < threads.Length; i++)
                threads[i] = new Thread(threadStart);
 
            foreach (var thread in threads) thread.Start(new ArraySegment<int>(myIntArray, 5, 25)); // example
            foreach (var thread in threads) thread.Join();

@Castello2401 · 28.02.2015, 10:41 **[ТС]**

То, что надо.

Добавлено через 20 минут
С использованием ArraySegment получился вот такой код:

C#

            int[] array = new int[] { 1, 2, 3, 4, 5, 6, 7, 8 };
 
            ParameterizedThreadStart threadStart = new ParameterizedThreadStart((segment) =>
            {
                foreach (var data in (IEnumerable<int>)segment)
                {
                    Console.WriteLine(data);
                    /// blablabla
                }
            });
 
            Thread[] threads = new Thread[Environment.ProcessorCount];
 
            for (int i = 0; i < threads.Length; i++)
                threads[i] = new Thread(threadStart);
 
            int offset;
            int count = array.Length / Environment.ProcessorCount;
            
            for (int i = 0; i < Environment.ProcessorCount; i++)
            {
                offset = i * count;
                ArraySegment<int> segment = new ArraySegment<int>(array, offset, count);
                threads[i].Start(segment);
            }
 
            foreach (var thread in threads) thread.Join();

Осталось решить вопрос с нечетносью переменной count

@kolorotur · 01.03.2015, 19:05

Сообщение от Castello2401

Осталось решить вопрос с нечетносью переменной count

Остаток пусть обрабатывает последний поток — не треснет

@Castello2401 12 / 12 / 5 Регистрация: 06.03.2012 Сообщений: 182
		1
	Разбить массив элементов на приблизительно равные части 26.02.2015, 10:14. Показов 2382. Ответов 6 Метки нет (Все метки) Есть массив элементов, нужно разбить его на Environment.ProcessorCount массивов, с приблизительно равными элементами. 0

@kolorotur 17685 / 12871 / 3365 Регистрация: 17.09.2011 Сообщений: 21,136
	27.02.2015, 20:08	3
	Сообщение от Castello2401 Есть массив элементов, нужно разбить его на Environment.ProcessorCount массивов Судя по тому, что нужно Environment.ProcessorCount частей, могу предположить, что вы собираетесь обрабатывать массив в разных потоках, а раз это нужно всего лишь для обработки, то зачем его вообще разбивать? В каждый поток отправляйте ссылку на массив, с какого индекса начинать и сколько элементов обрабатывать. И пусть все потоки работают с одним и тем же массивом. 0

@kolorotur 17685 / 12871 / 3365 Регистрация: 17.09.2011 Сообщений: 21,136
	01.03.2015, 19:05	7
	Сообщение от Castello2401 Осталось решить вопрос с нечетносью переменной count Остаток пусть обрабатывает последний поток — не треснет 0