Сейчас обсуждают

[BloodSeeker]

Ребят, я в java - полный профан, если честно. В шарпе и плюсах норм все вроде, разобрался со стандартными вещами + open mp. Помогите, как распараллелить САМЫЙ простой цикл в java?
Что-нибудь наподобие

Код

for (int i = 0; i < a.length; i++)
                for (int j = 0; j < x.length; j++)
                    xk[i] += a[i][j] * x[j];

Начал про Threads что-то читать, но до конца не вкупил - то ли не там читал, то ли еще что. Но насколько я понял, для каждого распараллеливаемого цикла надо несколько классов писать (для каждого диапазона рассматриваемых значений), и потом создавать объект thread этих классов и запускать их. А у меня в проге много циклов, каждый разбивать и переписывать вручную запаришься...

[BloodSeeker]

Нашел еще в интернете статью по Executor. Покопался, вроде немного разобрался, что да с чем, но, видимо, не полностью. Все испортила какая-то неведомая ошибка:

Exception in thread "main" java.util.concurrent.RejectedExecutionException: Task main.Main$Task@566dab9b rejected from java.util.concurrent.ThreadPoolExecutor@3a1d7971[Terminated, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 100000]
at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2048)
at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:821)
at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1372)
at main.Main.calcProperNumber1(Main.java:71)
at main.Main.main(Main.java:30)

В таком коде:

» Спойлер (нажмите, чтобы прочесть) «

Это сама распараллеливаемая функция

Код

public static class Task implements Runnable
    {
        public double[][] a1;
        public double[] x1, l1;
        public Task(double[][] a, double[] x)
        {
            a1 = a;
            x1 = x;
        }
        @Override
        public void run()
        {
//            double xk[] = new double[x1.length];
            for (int i = 0; i < a1.length; i++)
                for (int j = 0; j < x1.length; j++)
                    xk[i] += a1[i][j] * x1[j];
        }
    }

А это вызывающая функция

Код

    public static double calcProperNumber1(double[][] a, double[] x, double[] l)
    {
        double currentLambda, lastLambda = 0.0d;
        Thread threads[] = new Thread[100000];
        ThreadPoolExecutor executor = (ThreadPoolExecutor) Executors.newCachedThreadPool();
        while (true) {
            Arrays.fill(xk, 0);
            for (int i = 0; i < threads.length; i++)
            {
            Task task = new Task(a,x);
            executor.execute(task);         //вот тут ошибка вылезает
            }
            executor.shutdown();
            try
            {
                executor.awaitTermination(1, TimeUnit.DAYS);
            }
            catch (InterruptedException e)
            {
                e.printStackTrace();
            }
...........................

Может, кто сталкивался?

[mephisto]

100000 не многовато ли? Особенно в задаче, где на IO ничего не завязано?

Переводчик из меня плохой, поэтому я лишь выделю наиболее интересное место в цитате.
http://docs.oracle.com/javase/7/docs/api/j...olExecutor.html

New tasks submitted in method execute(java.lang.Runnable) will be rejected when the Executor has been shut down, and also when the Executor uses finite bounds for both maximum threads and work queue capacity, and is saturated. In either case, the execute method invokes the RejectedExecutionHandler.rejectedExecution(java.lang.Runnable, java.util.concurrent.ThreadPoolExecutor) method of its RejectedExecutionHandler.

[mephisto]

А еще, создание нити может быть не дешевой операцией (зависит от ОС и реализации в ЯП). Лучше не создавать нить на каждые «2×2», а обрабатывать в одной ните несколько заданий так, чтобы она проработала значительно больше времени, чем требуется на её создание и «уничтожение».

[BloodSeeker]

100000 не многовато ли? Особенно в задаче, где на IO ничего не завязано?

Переводчик из меня плохой, поэтому я лишь выделю наиболее интересное место в цитате.
http://docs.oracle.com/javase/7/docs/api/j...olExecutor.html

Уменьшил до 4, потом до 2, ошибка не изменилась =(

[mephisto]

Ну значит самая заметная ошибка оказалась не единственной.

Убери из кода странные вещи, вроде массива threads, от которого используется только length. Почитай статью по теме. Если не поможет — пости весь код.

Есть подозрение, что должно быть по экземпляру ThreadPoolExecutor на тред, ограничусь предположением, лезти в документацию в такое время лень.