今回はスレッドの作成に重点を置いて勉強します。
<h2>スレッド</h2>
<ul>
<li>Javaプログラムは最初に1つのスレッドを持つ
<ul>
<li>開発者が存在を検知できないバックグラウンドのスレッドを除く</li>
</ul>
</li>
<li>新しいスレッドを作成するプログラムをマルチスレッドと呼ぶ</li>
<li>スレッドがCPUコア数以上の場合タイムスライスという動作をする
<ul>
<li>タイムスライスとは一定時間実行した後に別のスレッドに実行を譲る動作</li>
<li>短い時間で実行を切り替えるために並行動作するように見える</li>
</ul>
</li>
<li>実行中のスレッド側は突然処理が割り込まれて処理が停止する。
<ul>
<li>プリエンプションという</li>
</ul>
</li>
<li>新しいスレッドは、スレッド生成時に指定したメソッドから実行開始する</li>
<li>変数の値を複数スレッドが同時に更新すると不整合が発生する
<ul>
<li>防ぐ手段同期処理（高難易度）排他制御
<ul>
<li>同期処理（高難易度）</li>
<li>排他制御</li>
</ul>
</li>
</ul>
</li>
<li>スレッドの横取りが起きないことが保証されている操作をアトミックな操作と呼ぶ
<ul>
<li>ロックをかけることで横取りによる不整合を防ぐ</li>
</ul>
</li>
</ul>
大事なことはマルチスレッドから呼ばれても問題のないコードを書く技術
<h2>Runnableインターフェース</h2>
Thread生成時にはRunnableオブジェクトを渡し、runメソッドがエントリポイントとして実行されます。Runnableはインターフェースなので実装クラスが必要になりますが、@FunctionalInterfaceがついた関数型インターフェースなので、ラムダ式で引数無し戻り値無しの関数を渡すこともできます。
<div class="remark-highlight"><pre class="language-java"><code class="language-java">@FunctionalInterface
public interface Runnable {
 /**
 * When an object implementing interface {@code Runnable} is used
 * to create a thread, starting the thread causes the object's
 * {@code run} method to be called in that separately executing
 * thread.
 * &#x3C;p>
 * The general contract of the method {@code run} is that it may
 * take any action whatsoever.
 *
 * @see java.lang.Thread#run()
 */
 public abstract void run();
}
</code></pre></div>
<div class="remark-highlight"><pre class="language-java"><code class="language-java">Thread t = new Thread(()->{
	 System.out.println("処理開始");
});
t.run();
</code></pre></div>
<h2>Callableインターフェース</h2>
Runnableのrunは戻り値がありませんが、Callableインターフェースを利用することで戻り値を利用できます（スレッドが値を返す =スレッドの実行結果を取得できる)
Callableも関数型インターフェースなのでわざわざ実装クラスを作る必要はありません
<div class="remark-highlight"><pre class="language-java"><code class="language-java">@FunctionalInterface
public interface Callable&#x3C;V> {
 /**
 * Computes a result, or throws an exception if unable to do so.
 *
 * @return computed result
 * @throws Exception if unable to compute a result
 */
 V call() throws Exception;
}
</code></pre></div>
Thread生成時にはRunnableを利用しましたが引数にマッチしません。CallableはFutureTaskや、スレッドプールとして使えるExecutorsと合わせて利用します。
<div class="remark-highlight"><pre class="language-java"><code class="language-java">FutureTask&#x3C;Integer> future = new FutureTask&#x3C;>(() -> 100);
		Thread t2 = new Thread(future);
		t2.start();
		System.out.println(future.get());
</code></pre></div>
ExecutorsはnewFixedThreadPoolメソッドでExecutorServiceを取得します。submitメソッドでcallableインターフェースを渡してタスクの結果をFutureに返し、getメソッドで結果を取得します
<div class="remark-highlight"><pre class="language-java"><code class="language-java">　　ExecutorService executor = Executors.newFixedThreadPool(8);
		executor.execute(()->{
			System.out.println("execute");
		});
		Future&#x3C;String> f = executor.submit(()->"submit");
		System.out.println(f.get());
		executor.shutdown();
</code></pre></div>
<div class="remark-highlight"><pre class="language-unknown"><code class="language-unknown">execute
submit</code></pre></div>
<h2>同期処理について</h2>
<a href="/posts/p1147">リンク</a>
<a href="/posts/p1212">リンク</a>
<a href="/posts/p854">リンク</a>
<h2>参考書籍</h2>
改訂2版　パーフェクトJava

Java | スレッド