Aritalab:Lecture/Programming/Java/Parallel2 - Revision history

Adm: /* Concurrentパッケージ */

2012-07-02T00:23:21Z

‎Concurrentパッケージ

Adm: /* Concurrentパッケージ */

2012-07-02T00:21:31Z

‎Concurrentパッケージ

Adm: Created page with "==Concurrentパッケージ== 非同期で多くの処理を行うときに便利なパッケージが java.util.concurrent です。簡単な使い方は * [http://www.techscore..."

2012-07-01T16:04:09Z

Created page with "==Concurrentパッケージ== 非同期で多くの処理を行うときに便利なパッケージが java.util.concurrent です。簡単な使い方は * [http://www.techscore..."

New page

==Concurrentパッケージ==
非同期で多くの処理を行うときに便利なパッケージが java.util.concurrent です。簡単な使い方は
* [http://www.techscore.com/tech/Java/JavaSE/Thread/7/ techscore マルチスレッドプログラミング]
* [http://jrm.stin.jp/index.php?itemid=111 落ちぶれプログラマの戯言]
にあります。
ここでは 20 個のタスクを 4 スレッドで処理する例を紹介します。ThreadPoolExecutor の設定が面倒に見えますが [http://java.sun.com/javase/ja/6/docs/ja/api/java/util/concurrent/ThreadPoolExecutor.html Java6 のAPI仕様] をみてパラメータをうまく設定して下さい。ここでは長さを指定しない LinkedBlockingQueue を用いていますが、プログラム中で実行するタスクの数を調節しています。また終了するには exec.shutdown() を呼ぶのを忘れずにおこなって下さい。

<pre>
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class ThreadTest {
BlockingQueue<Runnable> queue = new LinkedBlockingQueue<Runnable>(4);
ThreadPoolExecutor exec = new ThreadPoolExecutor(4 /* corePoolSize */,
4 /* maxPoolSize */, 0 /* keepAliveTime */, TimeUnit.MILLISECONDS, queue);

class Task extends Thread {
int id;
Task(int x) { id = x; }
public void run() {
try {
Thread.sleep((int) (Math.random() * 1000));
} catch (Exception e) {}
}
}

void report() {
System.out.println(exec.getTaskCount() + " tasks" + " (active:"
+ exec.getActiveCount() + " queue:" + queue.size() + ")");
}

void test() {
System.out.println("START");
try {
for (int i = 0; i < 20;) {
if (queue.remainingCapacity() > 0) {
exec.execute(new Task(i));
i++;
} else {
report();
Thread.sleep(500);
}
}
} catch (Exception e) {} finally { exec.shutdown(); }

while (!exec.isTerminated()) {
report();
try { Thread.sleep(1000); } catch(Exception e) {}
}
System.out.println("FINISH");
}

public static void main(String[] args) {
ThreadTest T = new ThreadTest();
T.test();
}
}
</pre>

@@ Line 27: / Line 27: @@
+   }
-   void report() {
+   void printStatus() {
      System.out.println(exec.getTaskCount() + " tasks" + " (active:"
          + exec.getActiveCount() + " queue:" + queue.size() + ")");
@@ Line 40: / Line 40: @@
            i++;
          } else {
-           report();
+           printStatus();
            Thread.sleep(500);
+         }
@@ Line 47: / Line 47: @@
      while (!exec.isTerminated()) {
-       report();
+       printStatus();
-      try { Thread.sleep(1000); } catch(Exception e) {}
+      try { Thread.sleep(500); } catch(Exception e) {}
+     }
      System.out.println("FINISH");

@@ Line 4: / Line 4: @@
 * [http://jrm.stin.jp/index.php?itemid=111 落ちぶれプログラマの戯言]
 にあります。
-ここでは 20 個のタスクを 4 スレッドで処理する例を紹介します。ThreadPoolExecutor の設定が面倒に見えますが [http://java.sun.com/javase/ja/6/docs/ja/api/java/util/concurrent/ThreadPoolExecutor.html Java6 のAPI仕様] をみてパラメータをうまく設定して下さい。ここでは長さを指定しない LinkedBlockingQueue を用いていますが、プログラム中で実行するタスクの数を調節しています。また終了するには exec.shutdown() を呼ぶのを忘れずにおこなって下さい。
+ここでは 20 個のタスクを 4 スレッドで処理する例を紹介します。ThreadPoolExecutor の設定が面倒に見えますが [http://java.sun.com/javase/ja/6/docs/ja/api/java/util/concurrent/ThreadPoolExecutor.html Java6 のAPI仕様] をみながらパラメータを設定して下さい。ここでは長さを指定しない LinkedBlockingQueue を用いていますが、プログラム中で実行するタスクの数を調節しています。また終了するには exec.shutdown() を呼ぶのを忘れずにおこなって下さい。
 <pre>