VPF::Распараллеливание циклов в java

nighthare

Дата 9.4.2009, 11:18 (ссылка)

(нет голосов)

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 37
Регистрация: 24.12.2005

Репутация: нет
Всего: нет

Есть цикл, пусть i пробегает от 0 до M. Внутри цикла, выполняемая операция( назовем ее функцией perform(int i) ) зависит только от i и не зависит от (i-1,I+1, i-2, i+2 и т.д.). Есть N процессоров. Как грамотно распараллелить такой цикл, используя java? Может есть framework или шаблоны для этого, с учетом, что если подобные циклы встречаются не один раз, можно легко(используя код, скоторый написан 1 раз) применить к ним распараллеливание. ?

Vitaly333

Дата 9.4.2009, 13:27 (ссылка)

(нет голосов)

Загрузка ...

Бывалый

Профиль
Группа: Участник
Сообщений: 220
Регистрация: 6.11.2006
Где: Volgograd

Репутация: 2
Всего: 2

Наверное, как - то так:

Код


public class Parallel {

    /**
     * @param args
     */
    public static void main(String[] args) {
        // TODO Auto-generated method stub

        // Цикл по i = (0...n)
        int n = 10; 
        int threadsCount = Runtime.getRuntime().availableProcessors(); // количество процессоров
        Processor[] ts = new Processor[threadsCount];
          
        int beg = 0;
        int mid = n/threadsCount;                                      
        int ost = 0;         
        if (n%threadsCount!=0)  ost = n - mid*threadsCount;         
        int end = mid+ost;
        
        for (int i=0;i<threadsCount;i++){
         ts[i] = new Processor(beg,end);          
            beg = end;
            end +=mid;
        }
        
        
    }

    // ваша функция
    public static void perform(int i){
        
        
        // какие - то действия...
    }
    
    
    

}

 class Processor extends Thread {
    
    int beg;
    int end;
    
    public Processor(int beg, int end) {
        this.beg = beg;
        this.end = end;    
        start();
    }
    
    @Override
    public void run() {                
        for (int i=beg;i<end;i++) Parallel.perform(i);            
    }
}

COVD

Дата 9.4.2009, 14:51 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 1655
Регистрация: 26.7.2005

Репутация: 17
Всего: 43

Для каждого i надо создать обьект типа Runnable , который в методе run() будет выполнять то, что в perform(i) должно быть. И эти обьекты ставить в очередь на выполнение в экзекютор , который есть пул потоков. Можно количество потоков в пуле сделать равным количеству процессоров.
http://java.sun.com/docs/books/tutorial/es...cy/exinter.html

0 Пользователей читают эту тему (0 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема \| Java: Общие вопросы \| Следующая тема »