Javaのレビューに基づいたマルチスレッドの詳細な説明

Thread.currentThread().setName("テスト");
Thread.currentThread().setPriority(Thread.MAX_PRIORITY);
名前 = Thread.currentThread().getName();
優先度 = Thread.currentThread().getPriority();
groupName = Thread.currentThread().getThreadGroup().getName();
isDaemon = Thread.currentThread().isDaemon();
System.out.println("スレッド名:" + 名前);
System.out.println("優先度:" + 優先度);

スレッド thread2 = 新しいスレッド("高")
{
public void run()
{
for (int i = 0; i < 5; i++)
{
System.out.println("スレッド 2 が実行中です。");
}
}
};

thread1.setPriority(Thread.MIN_PRIORITY);
thread2.setPriority(Thread.MAX_PRIORITY);
thread1.start();
thread2.start();
}

thread1.start();
}

public static void createThreadBySubClass()
{
MyThread スレッド = new MyThread();
thread.start();
}

public static void createThreadByRunnable()
{
MyRunnable runnable = new MyRunnable();
スレッド thread = 新しいスレッド (実行可能);
thread.start();
}

public static void main(String[] args) は InterruptedException をスローします
{
通知テスト();
通知テスト2();
通知テスト3();
}

private static void NoticeTest() が InterruptedException をスローする
{
MyThread[] arrThreads = 新しい MyThread[3];
for (int i = 0; i < arrThreads.length; i++)
{
arrThreads[i] = 新しい MyThread();
arrThreads[i].id = i;
arrThreads[i].setDaemon(true);
arrThreads[i].start();
}
Thread.sleep(500);
for (int i = 0; i < arrThreads.length; i++)
{
同期化(arrThreads[i])
{
arrThreads[i].notify();
}
}
}

private static void NoticeTest2() が InterruptedException をスローする
{
MyRunner[] arrMyRunners = 新しい MyRunner[3];
スレッド[] arrThreads = 新しいスレッド[3];
for (int i = 0; i < arrThreads.length; i++)
{
arrMyRunners[i] = 新しい MyRunner();
arrMyRunners[i].id = i;
arrThreads[i] = 新しいスレッド(arrMyRunners[i]);
arrThreads[i].setDaemon(true);
arrThreads[i].start();
}
Thread.sleep(500);
for (int i = 0; i < arrMyRunners.length; i++)
{
同期(arrMyRunners[i])
{
arrMyRunners[i].notify();
}
}
}

private static void NoticeTest3() が InterruptedException をスローする
{
MyRunner ランナー = new MyRunner();
スレッド[] arrThreads = 新しいスレッド[3];
for (int i = 0; i < arrThreads.length; i++)
{
arrThreads[i] = 新しいスレッド(ランナー);
arrThreads[i].setDaemon(true);
arrThreads[i].start();
}
Thread.sleep(500);

同期(ランナー)
{
ランナー.notifyAll();
}
}
}

クラス MyThread は Thread を拡張します
{
パブリック int ID = 0;
public void run()
{
System.out.println("スレッド " + id + " は 5 分間スリープする準備ができています。");
試す
{
同期済み(これ)
{
this.wait(5*60*1000);
}
}
catch(中断例外例)
{
ex.printStackTrace();
}
System.out.println("「番目」 + id + "スレッドが起動されました。");
}
}

MyRunner クラスは Runnable を実装します
{
パブリック int ID = 0;
public void run()
{
System.out.println("スレッド " + id + " は 5 分間スリープする準備ができています。");
試す
{
同期済み(これ)
{
this.wait(5*60*1000);
}
}
catch(中断例外例)
{
ex.printStackTrace();
}
System.out.println("「番目」 + id + "スレッドが起動されました。");
}

}

public static void main(String[] args) は InterruptedException をスローします
{
sleepTest();
}

private static void sleepTest() が InterruptedException をスローする
{
スレッド thread = new Thread()
{
public void run()
{
System.out.println("Thread" + Thread.currentThread().getName() + "5 分間スリープします。");
試す
{
Thread.sleep(5*60*1000);
}
catch(中断例外例)
{
System.out.println("スレッド" + Thread.currentThread().getName() + "スリープが中断されました。");
}
System.out.println("スレッド" + Thread.currentThread().getName() + "スリープが終了しました。");
}
};
thread.setDaemon(true);
thread.start();
Thread.sleep(500);
thread.interrupt();
}

}

public static void main(String[] args) は InterruptedException をスローします
{
stopTest();
}

private static void stopTest() が InterruptedException をスローする
{
スレッド thread = new Thread()
{
public void run()
{
System.out.println("スレッドは実行中です。");
試す
{
Thread.sleep(1*60*1000);
}
catch(中断例外例)
{
System.out.println("スレッド割り込み、スレッド終了");
戻る;
}
System.out.println("スレッドは正常に終了しました。");
}
};
thread.start();
Thread.sleep(500);
thread.interrupt();
}
}

public static void main(String[] args) は InterruptedException をスローします
{
joinTest();
}

private static void joinTest() が InterruptedException をスローする
{
スレッド thread = new Thread()
{
public void run()
{
試す
{
for(int i = 0; i < 5; i++)
{
System.out.println("スレッドは実行中です。");
Thread.sleep(1000);
}
}
catch(中断例外例)
{
ex.printStackTrace();
}
}
};
thread.setDaemon(true);
thread.start();
Thread.sleep(1000);
thread.join();
System.out.println("メインスレッドが正常に終了しました。");
}
}

スレッド thread1 = 新しい Thread()
{
public void run()
{
BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
試す
{
その間(真)
{
文字列メッセージ = br.readLine();
pos.write(message.getBytes());
if (message.equals("end")) ブレーク;
}
br.close();
pos.close();
}
catch(例外例)
{
ex.printStackTrace();
}
}
};

スレッド thread2 = 新しい Thread()
{
public void run()
{
byte[] バッファ = 新しいバイト [1024];
int bytesRead = 0;
試す
{
while((bytesRead = pis.read(buffer, 0,buffer.length)) != -1)
{
System.out.println(new String(buffer));
if (new String(buffer).equals("end")) ブレーク;
バッファ = null;
バッファ = 新しいバイト[1024];
}
pis.close();
バッファ = null;
}
catch(例外例)
{
ex.printStackTrace();
}
}
};

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

スレッド thread1 = 新しい Thread()
{
public void run()
{

BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
試す
{
その間(真)
{
文字列メッセージ = br.readLine();
bw.write(メッセージ);
bw.newLine();
bw.flush();
if (message.equals("end")) ブレーク;
}
br.close();
pw.close();
bw.close();
}
catch(例外例)
{
ex.printStackTrace();
}
}
};

スレッド thread2 = 新しい Thread()
{
public void run()
{

文字列行 = null;
試す
{
while((line = br.readLine()) != null)
{
System.out.println(line);
if (line.equals("end")) ブレーク;
}
br.close();
pr.close();
}
catch(例外例)
{
ex.printStackTrace();
}
}
};

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