Javaでは簡単にスレッドプールを利用できます。スレッドプールは生成したスレッドを待機させて、必要になったら利用し終わったらまた待機して使いまわす技法です。
スレッドを大量に生成することで実行性能に影響がある場合に、スレッドプールを利用して性能を上げることができます※スレッド生成自体は重い処理でなく極限までチューニングする手法として一般的。
<h2>スレッドプールを試す</h2>
Executorsを生成する際にスレッドプールのスレッド数を指定して、スレッドを使いまわしている様子を確認します。
<div class="remark-highlight"><pre class="language-java"><code class="language-java">public class Main {
	
	public static AtomicInteger count = new AtomicInteger();
	
	public static void execute() {
		System.out.println("current" + String.valueOf(count.incrementAndGet()));
	}

	public static void main(String[] args) {
		Runnable run = () -> {
			try {
				Thread.sleep(3000);
				execute();
				System.out.println("処理完了" + Thread.currentThread().getName());
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		};
		
		ExecutorService executor = Executors.newFixedThreadPool(3);
		executor.execute(run);
		executor.execute(run);
		executor.execute(run);
		executor.execute(run);
		executor.execute(run);
		executor.shutdown();
	}

}
</code></pre></div>
前回の記事のソースを使い回していますが、やっていることはアトミックなカウンターをインクリメントするだけです。この時スレッドを一時的にスリープして止めています。
スレッド数を3でスレッドプールを作成して、executeメソッドを5回実行することで5スレッド分の処理を実施します。
ログは以下のようになります
<div class="remark-highlight"><pre class="language-unknown"><code class="language-unknown">current1
処理完了pool-1-thread-1
current3
処理完了pool-1-thread-2
current2
処理完了pool-1-thread-3
current4
処理完了pool-1-thread-1
current5
処理完了pool-1-thread-2
</code></pre></div>
<div class="remark-highlight"><pre class="language-unknown"><code class="language-unknown"></code></pre></div>
スレッドプールは3スレッドしかないのでスレッドを使い回していることがわかります。
また、カウント4と5に関しては実行までにラグが生じます。これはスレッドプールが3つしかないので空いているスレッドがないから待機した状態になっているからです。
Executorを生成する際にシングルスレッドのみにするなど様々なメソッドが用意されています
<ul>
<li>newSingleThreadExecutor
<ul>
<li>1つのスレッドのみを使う。順番にタスクを処理していく</li>
</ul>
</li>
<li>newCachedThreadPool
<ul>
<li>必要に応じてスレッドを作成して、空いた場合は使い回す</li>
<li>短い時間に大量のタスクを行う時に便利</li>
</ul>
</li>
</ul>
などなど。
ためしにnewSingleThreadExecutorを使ってみます
<div class="remark-highlight"><pre class="language-java"><code class="language-java">ExecutorService executor = Executors.newSingleThreadExecutor();
</code></pre></div>
<div class="remark-highlight"><pre class="language-unknown"><code class="language-unknown">current1
処理完了pool-1-thread-1
current2
処理完了pool-1-thread-1
current3
処理完了pool-1-thread-1
current4
処理完了pool-1-thread-1
current5
処理完了pool-1-thread-1</code></pre></div>
タスクを順番に処理していくので時間がかかりますが、同じスレッドを使い回していることがわかります。
newCachedThreadPoolを利用すると、スレッドが5つ作成されて一気に処理されます
<div class="remark-highlight"><pre class="language-unknown"><code class="language-unknown">current1
処理完了pool-1-thread-5
current4
処理完了pool-1-thread-1
current2
処理完了pool-1-thread-2
current5
処理完了pool-1-thread-3
current3
処理完了pool-1-thread-4</code></pre></div>
このようにJavaでは簡単にスレッドプールが利用できるので、スレッドプールを自作することはしないで、既存機能を使えばOKです。

Java | スレッドプール