자바 프로그램을 병렬 처리하는 방법은 무엇입니까?

Question

병렬 프로그래밍을 사용하여 선형 방정식을 풀기 위해 java로 프로그램을 개발 중입니다. 나는 그것을 해결하기위한 코드를 작성했다. 멀티 코어 프로세서에서 작동하도록 수정하는 방법? 몇 가지 예를 들어 보겠습니다. mpi (메시지 전달 인터페이스)에 대해 들었습니다. 내 코드에서 어떻게 사용합니까?

Answer 1

당신이 할 수있는 일은 멀티 스레딩뿐입니다. OS 관리자가 여러 코어를 통해 프로세스를 공유하기를 바랍니다.

는 가장 간단한 방법은 ThreadPoolExecutors을 사용하는 것입니다 http://download.oracle.com/javase/1.5.0/docs/api/java/lang/Thread.html

Answer 2

를 참조하십시오, 당신은 튜토리얼 here을 볼 수 있습니다.

예는 수 :

import java.util.concurrent.*; 
import java.util.*; 

class MyThreadPoolExecutor 
{ 
    int poolSize = 2; 

    int maxPoolSize = 2; 

    long keepAliveTime = 10; 

    ThreadPoolExecutor threadPool = null; 

    final ArrayBlockingQueue<Runnable> queue = new ArrayBlockingQueue<Runnable>(
      5); 

    public MyThreadPoolExecutor() 
    { 
     threadPool = new ThreadPoolExecutor(poolSize, maxPoolSize, 
       keepAliveTime, TimeUnit.SECONDS, queue); 

    } 

    public void runTask(Runnable task) 
    { 
     // System.out.println("Task count.."+threadPool.getTaskCount()); 
     // System.out.println("Queue Size before assigning the 
     // task.."+queue.size()); 
     threadPool.execute(task); 
     // System.out.println("Queue Size after assigning the 
     // task.."+queue.size()); 
     // System.out.println("Pool Size after assigning the 
     // task.."+threadPool.getActiveCount()); 
     // System.out.println("Task count.."+threadPool.getTaskCount()); 
     System.out.println("Task count.." + queue.size()); 

    } 

    public void shutDown() 
    { 
     threadPool.shutdown(); 
    } 

    public static void main(String args[]) 
    { 
     MyThreadPoolExecutor mtpe = new MyThreadPoolExecutor(); 
     // start first one 
     mtpe.runTask(new Runnable() 
     { 
      public void run() 
      { 
       for (int i = 0; i < 10; i++) 
       { 
        try 
        { 
         System.out.println("First Task"); 
         Thread.sleep(1000); 
        } catch (InterruptedException ie) 
        { 
        } 
       } 
      } 
     }); 
     // start second one 
     /* 
     * try{ Thread.sleep(500); }catch(InterruptedException 
     * ie){} 
     */ 
     mtpe.runTask(new Runnable() 
     { 
      public void run() 
      { 
       for (int i = 0; i < 10; i++) 
       { 
        try 
        { 
         System.out.println("Second Task"); 
         Thread.sleep(1000); 
        } catch (InterruptedException ie) 
        { 
        } 
       } 
      } 
     }); 
     // start third one 
     /* 
     * try{ Thread.sleep(500); }catch(InterruptedException 
     * ie){} 
     */ 
     mtpe.runTask(new Runnable() 
     { 
      public void run() 
      { 
       for (int i = 0; i < 10; i++) 
       { 
        try 
        { 
         System.out.println("Third Task"); 
         Thread.sleep(1000); 
        } catch (InterruptedException ie) 
        { 
        } 
       } 
      } 
     }); 
     // start fourth one 
     /* 
     * try{ Thread.sleep(500); }catch(InterruptedException 
     * ie){} 
     */ 
     mtpe.runTask(new Runnable() 
     { 
      public void run() 
      { 
       for (int i = 0; i < 10; i++) 
       { 
        try 
        { 
         System.out.println("Fourth Task"); 
         Thread.sleep(1000); 
        } catch (InterruptedException ie) 
        { 
        } 
       } 
      } 
     }); 
     // start fifth one 
     /* 
     * try{ Thread.sleep(500); }catch(InterruptedException 
     * ie){} 
     */ 
     mtpe.runTask(new Runnable() 
     { 
      public void run() 
      { 
       for (int i = 0; i < 10; i++) 
       { 
        try 
        { 
         System.out.println("Fifth Task"); 
         Thread.sleep(1000); 
        } catch (InterruptedException ie) 
        { 
        } 
       } 
      } 
     }); 
     // start Sixth one 
     /* 
     * try{ Thread.sleep(500); }catch(InterruptedException 
     * ie){} 
     */ 
     mtpe.runTask(new Runnable() 
     { 
      public void run() 
      { 
       for (int i = 0; i < 10; i++) 
       { 
        try 
        { 
         System.out.println("Sixth Task"); 
         Thread.sleep(1000); 
        } catch (InterruptedException ie) 
        { 
        } 
       } 
      } 
     }); 
      mtpe.shutDown(); 
    } 

}