forループの各項目のマルチスレッド/並列化JAVA

Question

別のスレッドが次のアイテムにアクセスしている間、各スレッドがforループの単一項目にアクセスしようとしています。私は、複数のスレッドを使用してこれを行いたいと、作成された複数のスレッドの数は、ユーザーによって入力されます。私はこれをexecutorserviceとストリームを使って行っています。私は単純なスレッドを使ってこれをやりたい以下は正しいですか？より良い方法がありますか？

Map<String, String> fileMap = new HashMap<>(); 
fileMap.put("Age", "Age is not remotely associated with it."); 
fileMap.put("Gender", "Gender plays a role but not that important."); 
fileMap.put("Money", "People do not believe but this is the only factor that matters."); 

Runnable myRunnable = new Runnable(){ 
    public void run(){ 
     for (Map.Entry<String, String> entry : fileMap.entrySet()) { 
      synchronized(this){ 
       int counter = 0; 
       Pattern p = Pattern.compile("not"); 
       Matcher m = p.matcher(entry.getValue()); 
       while (m.find()) { 
        counter++; 
       } 
       System.out.println("File Name: " + entry.getKey()); 
       System.out.println("Count: " + counter); 
       System.out.println(Thread.currentThread().getName()); 
      } 
     } 
    }  
}; 

int n = Integer.parseInt(args[0]); 
for (int x=0; x<n; x++) 
{ 
    Thread temp= new Thread(myRunnable, "Thread #" + x); 
    temp.start(); 
    System.out.println("Started Thread:" + x); 
} 

また、それは以前のスレッドがすでに値を計算しているので、バック前の項目に移動するにはいないのスレッドを持つことが可能でしょうか？ ご協力いただければ幸いです。ありがとう

Answer 1

ここにあなたの問題の解決策があります。これは、スレッド名を解析してインデックスを提供し、最後の配列を使用してスレッドにデータを渡す処理を行います。

Map<String, String> fileMap = new HashMap<>(); 
fileMap.put("Age", "Age is not remotely associated with it."); 
fileMap.put("Gender", "Gender plays a role but not that important."); 
fileMap.put("Money", "People do not believe but this is the only factor that matters."); 


final int[] tgSize = new int[]{0}; 
final Map.Entry[][] entryArr = new Map.Entry[1][]; 

Runnable myRunnable = new Runnable(){ 
    public void run(){ 
     Integer index = Integer.valueOf(Thread.currentThread().getName().substring(8)); 

     for(int i = index; i < fileMap.size(); i += tgSize[0]) { 
      int counter = 0; 
      @SuppressWarnings("unchecked") 
      Map.Entry<String, String> entry = entryArr[0][i]; 
      Pattern p = Pattern.compile("not"); 
      Matcher m = p.matcher(entry.getValue()); 
      while (m.find()) { 
       counter++; 
      } 
      synchronized(this) { 
       System.out.println("File Name: " + entry.getKey()); 
       System.out.println("Count: " + counter); 
       System.out.println(Thread.currentThread().getName());    
      } 
     } 
    }  
}; 

int n = Integer.parseInt(args[0]); 

tgSize[0] = n < fileMap.size() ? n : fileMap.size(); 
entryArr[0] = fileMap.entrySet().toArray(new Map.Entry[fileMap.size()]); 


for (int x=0; x<n && x < fileMap.size(); x++) 
{ 
    Thread temp= new Thread(myRunnable, "Thread #" + x); 
    temp.start(); 
    System.out.println("Started Thread:" + x); 
} 

Answer 2

自分でマルチスレッドコードの書き方を学びたいのであればそれはAbacusUtil

final Pattern p = Pattern.compile("not"); 

Stream.of(fileMap).parallel(threadNum).map(entry -> { 
    Matcher m = p.matcher(entry.getValue()); 
    int count = 0; 
    while (m.find()) { 
     count++; 
    } 
    return Pair.of(entry.getKey(), count); 
}).forEach(entry -> { 
    N.println("File Name: " + entry.getKey() + ", Count: " + entry.getValue()); 
}); 

によってparalledStreamによって達成することができます。ここに簡単なサンプルがあります：

final int threadNum = 3; 
final ExecutorService executorService = Executors.newFixedThreadPool(threadNum); 
final Iterator<Entry<String, String>> iter = fileMap.entrySet().iterator(); 

for (int i = 0; i < threadNum; i++) { 
    executorService.execute(new Runnable() { 
     @Override 
     public void run() { 
      Entry<String, String> entry = null; 
      while (true) { 
       synchronized (iter) { 
        if (iter.hasNext() == false) { 
         break; 
        } 
        entry = iter.next(); 
       } 

       final Matcher m = p.matcher(entry.getValue()); 
       int count = 0; 
       while (m.find()) { 
        count++; 
       } 

       System.out.println("File Name: " + entry.getKey() + ", Count: " + count + ", thread: " + Thread.currentThread().getName()); 
      } 
     } 
    }); 
} 

宣言：私はAbacusUtilの開発者です。

Answer 3

問題を使用して、配列を反復処理する生のスレッドを使用してループを並列化する標準的な方法を以下に示します。

import java.util.*; 
import java.util.regex.*; 

public class MyClass { 

public static void main(String[] args) { 
    Map<String, String> fileMap = new HashMap<>(); 
    fileMap.put("Age", "Age is not remotely associated with it."); 
    fileMap.put("Gender", "Gender plays a role but not that important."); 
    fileMap.put("Money", "People do not believe but this is the only factor that matters."); 
    String[] keys = fileMap.keySet().toArray(new String[fileMap.size()]); 

    int n = 2; //Integer.parseInt(args[0]); 
    for (int x=0; x<n; x++) 
    { 
     Runnable myRunnable = new MyRunnable(fileMap, keys, x, n); 
     Thread temp= new Thread(myRunnable); 
     temp.start(); 
     //System.out.println("Started Thread:" + x); 
    } 
} 

    private static class MyRunnable implements Runnable { 
     private Map<String, String> fileMap; 
     private String[] keys; 
     private int threadID; 
     private int threadCount; 
     Pattern p = Pattern.compile("not"); 
     public MyRunnable(Map<String, String> fileMap, String[] keys, int threadID, int threadCount) { 
      this.fileMap = fileMap; 
      this.keys = keys; 
      this.threadID = threadID; 
      this.threadCount = threadCount; 
     } 
     public void run(){ 
      for (int i=threadID; i<keys.length; i+= threadCount) { 
       int counter = 0; 
       Matcher m = p.matcher(fileMap.get(keys[i])); 
       while (m.find()) { 
        counter++; 
       } 
       synchronized(MyClass.class){ 
        System.out.println("File Name: " + keys[i]); 
        System.out.println("Count: " + counter); 
        System.out.println("ThreadID: " + threadID); 
       } 
      } 
     }  
    } 
    }