Javaレビューに基づいたマルチスレッド同期の使用方法の詳細な説明

public void run()
{
System.out.println(Thread.currentThread().getName() + " 開始。");
for (int i = 1; i <= 100; i++)
{
合計 += i;
}
試す {
Thread.sleep(500);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName() + " --- sum の値は " + sum);
System.out.println(Thread.currentThread().getName() + " End.");
}
}

private static voidsharedVaribleTest() が InterruptedException をスローする
{
MyRunner ランナー = new MyRunner();
スレッド thread1 = 新しいスレッド (ランナー);
スレッド thread2 = 新しいスレッド(ランナー);
thread1.setDaemon(true);
thread2.setDaemon(true);
thread1.start();
thread2.start();
thread1.join();
thread2.join();
}

private static void syncTest() が InterruptedException をスローする
{
MyNonSyncRunner ランナー = new MyNonSyncRunner();
スレッド thread1 = 新しいスレッド (ランナー);
スレッド thread2 = 新しいスレッド(ランナー);
thread1.setDaemon(true);
thread2.setDaemon(true);
thread1.start();
thread2.start();
thread1.join();
thread2.join();
}

private static voidsharedVaribleTest3() が InterruptedException をスローする
{
MyRunner2 ランナー = 新しい MyRunner2();
スレッド thread1 = 新しいスレッド (ランナー);
スレッド thread2 = 新しいスレッド(ランナー);
thread1.setDaemon(true);
thread2.setDaemon(true);
thread1.start();
thread2.start();
thread1.join();
thread2.join();
}

public void run()
{
System.out.println(Thread.currentThread().getName() + " 開始。");
for (int i = 0; i <= 100; i++)
{
if (tl.get() == null)
{
tl.set(新しい整数(0));
}
int sum = ((整数)tl.get()).intValue();
和+= i;
tl.set(新しい整数(合計));
試す {
Thread.sleep(10);
} catch (InterruptedException e) {
e.printStackTrace();
}
}

System.out.println(Thread.currentThread().getName() + " --- 合計の値は " + ((Integer)tl.get()).intValue());
System.out.println(Thread.currentThread().getName() + " End.");
}
}

private static voidsharedVaribleTest4() が InterruptedException をスローする
{
MyRunner3 ランナー = 新しい MyRunner3();
スレッド thread1 = 新しいスレッド (ランナー);
スレッド thread2 = 新しいスレッド(ランナー);
thread1.setDaemon(true);
thread2.setDaemon(true);
thread1.start();
thread2.start();
thread1.join();
thread2.join();
}

private static void syncTest2() が InterruptedException をスローする
{
MySyncRunner ランナー = new MySyncRunner();
スレッド thread1 = 新しいスレッド (ランナー);
スレッド thread2 = 新しいスレッド(ランナー);
thread1.setDaemon(true);
thread2.setDaemon(true);
thread1.start();
thread2.start();
thread1.join();
thread2.join();
}

スレッド thread1 = 新しい Thread()
{
public void run()
{
System.out.println(Thread.currentThread().getName() + " 開始。");
ランダム r = 新しいランダム(100);
同期済み(リスト)
{
for (int i = 0; i < 5; i++)
{
list.add(new Integer(r.nextInt()));
}
System.out.println("リストのサイズは " + list.size());
}
試す
{
Thread.sleep(500);
}
catch(中断例外例)
{
ex.printStackTrace();
}
System.out.println(Thread.currentThread().getName() + " End.");
}
};

スレッド thread2 = 新しい Thread()
{
public void run()
{
System.out.println(Thread.currentThread().getName() + " 開始。");
ランダム r = 新しいランダム(100);
同期済み(リスト)
{
for (int i = 0; i < 5; i++)
{
list.add(new Integer(r.nextInt()));
}
System.out.println("リストのサイズは " + list.size());
}
試す
{
Thread.sleep(500);
}
catch(中断例外例)
{
ex.printStackTrace();
}
System.out.println(Thread.currentThread().getName() + " End.");
}
};

thread1.start();
thread2.start();
thread1.join();
thread2.join();
}

列挙型スレッドタスク
{
始める、
停止、
寝る、
起きろ
}

クラス MyThread は Thread を拡張します
{
パブリック ThreadStatus ステータス = ThreadStatus.Initial;
パブリック ThreadTask タスク。
public void run()
{
ステータス = ThreadStatus.Running;
その間(真)
{
試す {
Thread.sleep(3000);
if (ステータス == ThreadStatus.Sleeping)
{
System.out.println(Thread.currentThread().getName() + "スリープ状態に入ります。");
this.wait();
}
} catch (InterruptedException e) {
System.out.println(Thread.currentThread().getName() + "操作中にエラーが発生しました。");
ステータス = ThreadStatus.停止;
}
}
}
}

public static void manageThread(MyThread スレッド、ThreadTask タスク)
{
if (タスク == ThreadTask.Start)
{
if (thread.status == ThreadStatus.Running)
{
戻る;
}
if (thread.status == ThreadStatus.Stopped)
{
スレッド = 新しい MyThread();
}
thread.status = ThreadStatus.Running;
thread.start();

}
else if (タスク == ThreadTask.Stop)
{
if (thread.status != ThreadStatus.Stopped)
{
thread.interrupt();
thread.status = ThreadStatus.Stopped;
}
}
else if (タスク == ThreadTask.Sleep)
{
thread.status = ThreadStatus.Sleeping;
}
else if (タスク == ThreadTask.Wakeup)
{
thread.notify();
thread.status = ThreadStatus.Running;
}
}

public static String getThreadStatus(MyThread[] スレッド)
{
StringBuffer sb = new StringBuffer();
for (int i = 0; i < thread.length; i++)
{
sb.append(threads[i].getName() + "ステータス: " + thread[i].status).append("/r/n");
}
sb.toString()を返します;
}
}

public static void main(String[] args) が IOException をスローする
{
MyThreadPool プール = 新しい MyThreadPool(5);
}

プライベート int threadCount;
プライベート MyThread[] スレッド = null;

public MyThreadPool(int count) が IOException をスローする
{
this.threadCount = カウント;
スレッド = 新しい MyThread[カウント];
for (int i = 0; i < thread.length; i++)
{
スレッド[i] = 新しい MyThread();
スレッド[i].start();
}
初期化();
}

private void Init() が IOException をスローする
{
サーバーソケットサーバーソケット = 新しいサーバーソケット(5678);
その間(真)
{
最終ソケットsocket =serverSocket.accept();
スレッド thread = new Thread()
{
public void run()
{
試す
{
System.out.println("新しいソケット接続が検出されました。");
BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
PrintStream ps = new PrintStream(socket.getOutputStream());
文字列行 = null;
while((line = br.readLine()) != null)
{
System.out.println(line);
if (line.equals("カウント"))
{
System.out.println("スレッド プールには 5 つのスレッドがあります");
}
else if (line.equals("ステータス"))
{
文字列ステータス = MyThreadManager.getThreadStatus(threads);
System.out.println(ステータス);
}
else if (line.equals("StartAll"))
{
MyThreadManager.manageThread(スレッド, ThreadTask.Start);
}
else if (line.equals("StopAll"))
{
MyThreadManager.manageThread(スレッド, ThreadTask.Stop);
}
else if (line.equals("SleepAll"))
{
MyThreadManager.manageThread(スレッド, ThreadTask.Sleep);
}
else if (line.equals("WakeupAll"))
{
MyThreadManager.manageThread(スレッド, ThreadTask.Wakeup);
}
else if (line.equals("End"))
{
壊す;
}
それ以外
{
System.out.println("コマンド:" + line);
}
ps.println("OK");
ps.flush();
}
}
catch(例外例)
{
ex.printStackTrace();
}
}
};
thread.start();
}
}
}

MyRunner ランナー = new MyRunner();

最終的な ScheduledFuture<?> handler1 =Scheduler.scheduleAtFixedRate(runner, 1, 10, TimeUnit.SECONDS);
最終的な ScheduledFuture<?> handler2 =Scheduler.scheduleWithFixedDelay(runner, 2, 10, TimeUnit.SECONDS);

スケジューラ.schedule(new Runnable()
{
public void run()
{
ハンドラー1.キャンセル(true);
ハンドラー2.キャンセル(true);
スケジューラー.シャットダウン();
}
}, 30, TimeUnit.SECONDS
);
}

Thread.sleep(1000);
for(int i = 0; i < 10; i++)
{
Future<String> 結果 = service.take();
System.out.println("スレッドの戻り値は " + result.get());
}
exec.shutdown();
}

public static void main(String[] args)
{
ブロックキューテスト();
}

プライベート静的無効blockingQueueTest()
{
最終 BlockingQueue<Integer> キュー = new LinkedBlockingQueue<Integer>();
最終 int maxSleepTimeForSetter = 10;
最終 int maxSleepTimerForGetter = 10;

実行可能セッター = new Runnable()
{
public void run()
{
ランダム r = 新しいランダム();
その間(真)
{
int 値 = r.nextInt(100);
試す
{
queue.put(新しい整数(値));
System.out.println(Thread.currentThread().getName() + "---キューに値を挿入" + value);
Thread.sleep(r.nextInt(maxSleepTimeForSetter) * 1000);
}
catch(例外例)
{
ex.printStackTrace();
}
}
}
};

実行可能ゲッター = new Runnable()
{
public void run()
{
ランダム r = 新しいランダム();
その間(真)
{
試す
{
if (queue.size() == 0)
{
System.out.println(Thread.currentThread().getName() + "---キューは空です");
}
それ以外
{
int 値 = queue.take().intValue();
System.out.println(Thread.currentThread().getName() + "---キューから値を取得" + value);
}
Thread.sleep(r.nextInt(maxSleepTimerForGetter) * 1000);
}
catch(例外例)
{
ex.printStackTrace();
}
}
}
};

ExecutorService exec = Executors.newFixedThreadPool(2);
exec.execute(setter);
exec.execute(getter);
}
}

for (int i = 0; i < 10; i++)
{
実行可能ランナー = new Runnable()
{
public void run()
{
試す
{
semp.acquire();
System.out.println(new Date() + " " + Thread.currentThread().getName() + "実行中。");
Thread.sleep(5000);
semp.release();
}
catch(例外例)
{
ex.printStackTrace();
}
}
};
exec.execute(ランナー);
}

exec.shutdown();
}

public void run() {
ランダム r = 新しいランダム();
試す
{
for (int i = 0; i < 3; i++)
{
Thread.sleep(r.nextInt(10) * 1000);
System.out.println(new Date() + "--" + Thread.currentThread().getName() + "--th" + (i + 1) + "wait.");
バリア.await();
}
}
catch(例外例)
{
ex.printStackTrace();
}
}

}

プライベート静的 void cyclicBarrierTest()
{
CyclicBarrier バリア = new CyclicBarrier(3);

ExecutorService exec = Executors.newFixedThreadPool(3);
for (int i = 0; i < 3; i++)
{
exec.execute(新しいMyRunner2(バリア));
}
exec.shutdown();
}