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 = 새 스레드("높음")
{
공개 무효 실행()
{
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();
}

공개 정적 무효 createThreadBySubClass()
{
MyThread 스레드 = 새로운 MyThread();
thread.start();
}

공개 정적 무효 createThreadByRunnable()
{
MyRunnable 실행 가능 = 새로운 MyRunnable();
스레드 스레드 = 새 스레드(실행 가능);
thread.start();
}

public static void main(String[] args)에서 InterruptedException이 발생합니다.
{
통지테스트();
통지테스트2();
통지테스트3();
}

개인 정적 무효 통지 테스트()가 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 informTest2()가 InterruptedException을 발생시킵니다.
{
MyRunner[] arrMyRunners = 새로운 MyRunner[3];
Thread[] arrThreads = 새 스레드[3];
for (int i = 0; i < arrThreads.length; i++)
{
arrMyRunners[i] = 새로운 MyRunner();
arrMyRunners[i].id = i;
arrThreads[i] = new Thread(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 informTest3()에서 InterruptedException이 발생합니다.
{
MyRunner 러너 = new MyRunner();
Thread[] 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;
공개 무효 실행()
{
System.out.println("Thread " + id + "는 5분 동안 절전 모드로 전환될 준비가 되어 있습니다.");
노력하다
{
동기화됨(이것)
{
this.wait(5*60*1000);
}
}
catch(InterruptedException ex)
{
ex.printStackTrace();
}
System.out.println(""th" + id + "스레드가 활성화되었습니다.");
}
}

MyRunner 클래스는 Runnable을 구현합니다.
{
공개 int ID = 0;
공개 무효 실행()
{
System.out.println("Thread " + id + "는 5분 동안 절전 모드로 전환될 준비가 되어 있습니다.");
노력하다
{
동기화됨(이것)
{
this.wait(5*60*1000);
}
}
catch(InterruptedException ex)
{
ex.printStackTrace();
}
System.out.println(""th" + id + "스레드가 활성화되었습니다.");
}

}

public static void main(String[] args)에서 InterruptedException이 발생합니다.
{
수면 테스트();
}

개인 정적 무효 sleepTest()가 InterruptedException을 발생시킵니다.
{
스레드 스레드 = 새 스레드()
{
공개 무효 실행()
{
System.out.println("Thread" + Thread.currentThread().getName() + "5분 동안 절전 모드로 전환됩니다.");
노력하다
{
Thread.sleep(5*60*1000);
}
catch(InterruptedException ex)
{
System.out.println("Thread" + Thread.currentThread().getName() + "Sleep이 중단되었습니다.");
}
System.out.println("스레드" + Thread.currentThread().getName() + "슬립이 종료되었습니다.");
}
};
thread.setDaemon(true);
thread.start();
Thread.sleep(500);
스레드.인터럽트();
}

}

public static void main(String[] args)에서 InterruptedException이 발생합니다.
{
중지테스트();
}

개인 정적 무효 stopTest()가 InterruptedException을 발생시킵니다.
{
스레드 스레드 = 새 스레드()
{
공개 무효 실행()
{
System.out.println("스레드가 실행 중입니다.");
노력하다
{
Thread.sleep(1*60*1000);
}
catch(InterruptedException ex)
{
System.out.println("스레드 인터럽트, 스레드 종료");
반품;
}
System.out.println("스레드가 정상적으로 종료되었습니다.");
}
};
thread.start();
Thread.sleep(500);
스레드.인터럽트();
}
}

public static void main(String[] args)에서 InterruptedException이 발생합니다.
{
JoinTest();
}

개인 정적 무효 JoinTest()가 InterruptedException을 발생시킵니다.
{
스레드 스레드 = 새 스레드()
{
공개 무효 실행()
{
노력하다
{
for(int i = 0; i < 5; i++)
{
System.out.println("스레드가 실행 중입니다.");
Thread.sleep(1000);
}
}
catch(InterruptedException ex)
{
ex.printStackTrace();
}
}
};
thread.setDaemon(true);
thread.start();
Thread.sleep(1000);
thread.join();
System.out.println("메인 스레드가 정상적으로 종료되었습니다.");
}
}

스레드 thread1 = 새 스레드()
{
공개 무효 실행()
{
BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
노력하다
{
동안(사실)
{
문자열 메시지 = br.readLine();
pos.write(message.getBytes());
if (message.equals("end")) break;
}
br.닫기();
pos.close();
}
catch(예외예외)
{
ex.printStackTrace();
}
}
};

스레드 thread2 = 새 스레드()
{
공개 무효 실행()
{
바이트[] 버퍼 = 새 바이트[1024];
int bytesRead = 0;
노력하다
{
while((bytesRead = pis.read(buffer, 0, buffer.length)) != -1)
{
System.out.println(새 문자열(버퍼));
if (new String(buffer).equals("end")) break;
버퍼 = 널;
버퍼 = 새 바이트[1024];
}
pis.close();
버퍼 = 널;
}
catch(예외예외)
{
ex.printStackTrace();
}
}
};

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

스레드 thread1 = 새 스레드()
{
공개 무효 실행()
{

BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
노력하다
{
동안(사실)
{
문자열 메시지 = br.readLine();
bw.write(메시지);
bw.newLine();
bw.플러시();
if (message.equals("end")) break;
}
br.닫기();
pw.close();
bw.close();
}
catch(예외예외)
{
ex.printStackTrace();
}
}
};

스레드 thread2 = 새 스레드()
{
공개 무효 실행()
{

문자열 라인 = null;
노력하다
{
while((line = br.readLine()) != null)
{
System.out.println(line);
if (line.equals("end")) break;
}
br.닫기();
pr.close();
}
catch(예외예외)
{
ex.printStackTrace();
}
}
};

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