Всем дорого времени суток!
Есть некоторый код, который принимает некоторые параметры и работает с ними, выдавая в конце "качество" работы некоторого алгоритма на этих параметрах. Для подбора наилучших параметров организую проход по координатной сетке, составленной как декартово произведение множеств параметров.
Так вот, если организовать последовательный прогон по, например, 16 значениям точек сетки, то время получается 577 секунд. Если запустить паралельное выполнение на 1 узле кластера (12 ядер - 24 потока с учетом hyperThreading) на 24 потока, то время в одной реализации 122 сек, в другой - 118 сек. Почему параллельное выполнение такое хилое? Ведь, по идее, запуск в 24 потока должен выполняться за время приближенное к 1 проходу, т.е. примерно секунд 40.
Вот одна параллельная реализация (122 сек, Parallel7__Dispatcher_PID_nonDimensional - класс имплементит Callable):
int processorsNumber = Runtime.getRuntime().availableProcessors(); // 24 потока
ExecutorService executer = Executors.newFixedThreadPool(processorsNumber);
List<Parallel7_Dispatcher_PID_nonDimensional> tasks = new LinkedList<Parallel7_Dispatcher_PID_nonDimensional>();
// в цикле 16 итераций
for ( int i = p_start; i < p_start + n; i++ ){
for ( int j = i_start; j < i_start + n; j++ ){
for ( int k = d_start; k < d_end; k++ ){
double kp = start_kp + (double) step * i;
double ki = start_ki + (double) step * j;
double kd = start_kd + (double) step * k;
tasks.add(new Parallel7_Dispatcher_PID_nonDimensional(kp, ki, kd));
}
}
}
List<Future<double[]>> res = executer.invokeAll(tasks);
for ( Future<double[]> future : res ){
double[] results = future.get();
synchronized (output) {
output.println(results[0] + "\t" + results[1] + "\t" + results[2] + "\t" + results[3]);
}
}
И другая параллельная реализация (118 сек, Parallel7__Dispatcher_PID_nonDimensional_2 - имплементит Runnable):
ArrayList<Parallel7_Dispatcher_PID_nonDimensional_2> tasks = new ArrayList<Parallel7_Dispatcher_PID_nonDimensional_2>();
for ( int i = p_start; i < p_start + n; i++ ){
for ( int j = i_start; j < i_start + n; j++ ){
for ( int k = d_start; k < d_end; k++ ){
double kp = start_kp + (double) step * i;
double ki = start_ki + (double) step * j;
double kd = start_kd + (double) step * k;
tasks.add(new Parallel7_Dispatcher_PID_nonDimensional_2(kp, ki, kd));
}
}
}
try {
for ( Parallel7_Dispatcher_PID_nonDimensional_2 task : tasks ){
task.thread.join();
}
} catch (InterruptedException e) {
e.printStackTrace();
}
for ( Parallel7_Dispatcher_PID_nonDimensional_2 task : tasks ){
output.println(task.getKp() + "\t" + task.getKi + "\t" + task.getKd() + "\t" + task.getValue());
}
UPD
Засекал время прямо с начала программы. Общее время выполнения, например, первой (долгой) параллельной реализации — 137 сек
А вот что касается по времени каждого задания (только его время, ничего больше):
1 125677.0
2 122276.0
3 131641.0
4 112568.0
5 128192.0
6 130366.0
7 130021.0
8 126856.0
9 134224.0
10 131822.0
11 132999.0
12 137035.0
13 120061.0
14 128839.0
15 125855.0
16 115646.0
Вот, что дает запуск последовательной версии программы:
1 37206
2 35664
3 35701
4 35962
5 35764
6 35940
7 35795
8 35741
9 35700
10 35796
11 35781
12 35650
13 35777
14 35958
15 35819
16 35820
Общее время — 577 сек.
Почему-то в параллельной реализации задание так долго выполняется... почему так может быть?