Java 並行処理を行う例 - 版の履歴

2020年2月16日 (日) 04:27にPirotoによる

2020-02-16T04:27:23Z

2020年2月15日 (土) 08:36にPirotoによる

2020-02-15T08:36:35Z

2020年2月15日 (土) 08:03にPirotoによる

2020-02-15T08:03:26Z

Piroto: ページの作成:「 ==Java 並行処理を行う例== [Java]{{category コード片}} ===並行処理コード抜粋=== package info.typea.checker; import info.typea.checker.S…」

2020-02-15T07:33:11Z

ページの作成:「 ==Java 並行処理を行う例== [Java]{{category コード片}} ===並行処理コード抜粋=== package info.typea.checker; import info.typea.checker.S…」

新規ページ

==Java 並行処理を行う例==
[Java]{{category コード片}}

===並行処理コード抜粋===
package info.typea.checker;

import info.typea.checker.SourceCodeAnalyzer;
import info.typea.checker.SourceCodeParser;
import info.typea.checker.JavaProgram;
import info.typea.checker.checkcase.CheckCase;
import info.typea.checker.checkcase.FormatCheckCase;
import info.typea.checker.checkcase.InvalidSyntaxCheckCase;

import java.io.File;
import java.io.FileOutputStream;
import java.io.FilenameFilter;
import java.io.OutputStream;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

/**
* 並行処理でJavaソースコードをチェックする
*/
public class SourceCodeChecker {

private static final int THREAD_SIZE = 8; // スレッドプールのサイズ
private ExecutorService threadPool; // スレッドプール

/**
* @param args
* @throws Exception
*/
public static void main(String[] args) throws Exception {

if (args.length < 1) {
System.out.println(usage());
System.exit(-1);
}
String dirName = args[0];
SourceCodeChecker me = new SourceCodeChecker();
me.check(new File(dirName));
System.out.println("終了しました");
}

/**
* @param dir 対象ディレクトリ
* @throws Exception
*/
public void check(File dir) throws Exception {
if (!dir.exists() || !dir.isDirectory()) {
throw new IllegalArgumentException("対象ディレクトリが不正です");
}

// 出力先ディレクトリ作成
SimpleDateFormat sdf = (SimpleDateFormat) DateFormat.getInstance();
sdf.applyPattern("yyyyMMdd_hhmmss");
String outdirName = dir.getAbsolutePath() + File.separator + "out_" + sdf.format(new Date());
File outdir = new File(outdirName);

if (!outdir.exists()) {
if (!outdir.mkdirs()) {
throw new IllegalStateException("出力先ディレクトリが作成できません " + outdirName);
}
}

// ソースコードに対してチェックするタスクを追加する
List<CheckCase> cases = new ArrayList<CheckCase>();
cases.add(new FormatCheckCase());
cases.add(new InvalidSyntaxCheckCase());

// 対象ファイルを拡張子で判断
File[] files = dir.listFiles(new FilenameFilter(){
public boolean accept(File dir, String name) {
return name.toLowerCase().endsWith(".py") || name.toLowerCase().endsWith(".java");
}});

// ************* ここから並行処理 *******************
threadPool = Executors.newFixedThreadPool(THREAD_SIZE);
List<CheckTask> tasks = new ArrayList<CheckTask>();

for (File file : files) {
tasks.add(new CheckTask(file, outdir, cases));
}

// すべてのタスクの完了を待つ
List<Future<Long>> result = threadPool.invokeAll(tasks);

for (Future<Long> f : result) {
System.out.printf("終了しました... %d\n" , f.get());
}
// ************* ここまで並行処理 *******************
}

public static class CheckTask implements Callable<Long> {
private File file;
private File outdir;
List<CheckCase> cases;

/**
*
*/
public CheckTask(File file, File outdir, List<CheckCase> cases) {
this.file = file;
this.outdir = outdir;
this.cases = cases;
}
/* (non-Javadoc)
* @see java.util.concurrent.Callable#call()
*/
public Long call() throws Exception {
System.out.printf("処理開始... %s\n", file.getName());

File outfile = new File(outdir.getAbsolutePath() + File.separator + file.getName() + "_report.txt");
OutputStream out = new FileOutputStream(outfile);

SourceCodeParser parser = new SourceCodeParser();
JavaProgram pgm = parser.parse(file);

SourceCodeAnalyzer analyzer = new SourceCodeAnalyzer(pgm);
long ret = analyzer.analyze(cases);

pgm.printSource(out);

out.close();

return new Long(ret);
}
}
public static String usage() {
return "java SourceCodeChecker target directory";
}
}

@@ 2行目: / 2行目: @@
 ==Java 並行処理を行う例==
-[[Java]]{{category コード片}}
+[[Java]] | {{category コード片}}
 ===並行処理コード抜粋===

@@ 1行目: / 1行目: @@
-==Java 並行処理を行う例==
+==[[Java 並行処理を行う例]]==
-[[Java]] | {{category コード片}}
+[[Java]] | [[Category:コード片]]
 ===並行処理コード抜粋===
@@ 9行目: / 9行目: @@
   import info.typea.checker.SourceCodeAnalyzer;
   import info.typea.checker.SourceCodeParser;
-  import info.typea.checker.JavaProgram;
+  import info.typea.checker.[[Java]]Program;
   import info.typea.checker.checkcase.CheckCase;
   import info.typea.checker.checkcase.FormatCheckCase;
@@ 24行目: / 24行目: @@
   import java.util.List;
   import java.util.concurrent.Callable;
-  import java.util.concurrent.ExecutorService;
+  import java.util.concurrent.ExecutorSer[[vi]]ce;
   import java.util.concurrent.Executors;
   import java.util.concurrent.Future;
   /**
-   * 並行処理でJavaソースコードをチェックする
+   * 並行処理で[[Java]]ソースコードをチェックする
    */
   public class SourceCodeChecker {
-      private static final int THREAD_SIZE = 8; // スレッドプールのサイズ
+      private static final int TH[[R]]EAD_SIZE = 8; // スレッドプールのサイズ
-      private ExecutorService threadPool;       // スレッドプール
+      private ExecutorSer[[vi]]ce threadPool;       // スレッドプール
       /**
@@ 85行目: / 85行目: @@
           // ************* ここから並行処理 *******************
-          threadPool = Executors.newFixedThreadPool(THREAD_SIZE);
+          threadPool = Executors.newFixedThreadPool(TH[[R]]EAD_SIZE);
           List&lt;CheckTask&gt; tasks = new ArrayList&lt;CheckTask&gt;();
@@ 114行目: / 114行目: @@
               this.cases = cases;
+          }
-          /* (non-Javadoc)
+          /* (non-[[Java]]doc)
            * @see java.util.concurrent.Callable#call()
            */
@@ 124行目: / 124行目: @@
               SourceCodeParser parser = new SourceCodeParser();
-              JavaProgram pgm = parser.parse(file);
+              [[Java]]Program pgm = parser.parse(file);
               SourceCodeAnalyzer analyzer = new SourceCodeAnalyzer(pgm);

@@ 2行目: / 2行目: @@
 ==Java 並行処理を行う例==
-[Java]{{category コード片}}
+[[Java]]{{category コード片}}
 ===並行処理コード抜粋===
@@ 42行目: / 42行目: @@
       public static void main(String[] args) throws Exception {
-          if (args.length < 1) {
+          if (args.length &lt; 1) {
               System.out.println(usage());
               System.exit(-1);
@@ 74行目: / 74行目: @@
           // ソースコードに対してチェックするタスクを追加する
-          List<CheckCase> cases = new ArrayList<CheckCase>();
+          List&lt;CheckCase&gt; cases = new ArrayList&lt;CheckCase&gt;();
           cases.add(new FormatCheckCase());
           cases.add(new InvalidSyntaxCheckCase());
@@ 86行目: / 86行目: @@
           // ************* ここから並行処理 *******************
           threadPool = Executors.newFixedThreadPool(THREAD_SIZE);
-          List<CheckTask> tasks = new ArrayList<CheckTask>();
+          List&lt;CheckTask&gt; tasks = new ArrayList&lt;CheckTask&gt;();
           for (File file : files) {
@@ 93行目: / 93行目: @@
           // すべてのタスクの完了を待つ
-          List<Future<Long>> result = threadPool.invokeAll(tasks);
+          List&lt;Future&lt;Long&gt;&gt; result = threadPool.invokeAll(tasks);
-          for (Future<Long> f : result) {
+          for (Future&lt;Long&gt; f : result) {
               System.out.printf("終了しました... %d\n" , f.get());
+          }
@@ 101行目: / 101行目: @@
+      }
-      public static class CheckTask implements Callable<Long> {
+      public static class CheckTask implements Callable&lt;Long&gt; {
           private File file;
           private File outdir;
-          List<CheckCase> cases;
+          List&lt;CheckCase&gt; cases;
           /**
+           *
            */
-          public CheckTask(File file,  File outdir, List<CheckCase> cases) {
+          public CheckTask(File file,  File outdir, List&lt;CheckCase&gt; cases) {
               this.file = file;
               this.outdir = outdir;