스레드 응용 추가

src/kr/co/swh/lecture/java/scene4/ThreadHigh1A.java

@@ -0,0 +1,45 @@
+package kr.co.swh.lecture.java.scene4;
+
+/**
+ * <pre>
+ * kr.co.swh.lecture.java.scene4
+ * ThreadHigh1A.java
+ *
+ * 설명 : 쓰레드 고급 첫 번째 예제
+ * </pre>
+ * 
+ * @since : 2021. 12. 23.
+ * @author : tobby48
+ * @version : v1.0
+ */
+public class ThreadHigh1A extends Thread{
+	
+	private int sum = 0;
+	private int count = 0;
+	
+	@Override
+	public void run() {
+		// TODO Auto-generated method stub
+		synchronized(this){
+			while(true) {
+				count++;
+				sum += count;
+				if(count % 5 == 0) {
+					break;
+				}
+				System.out.println(count + "ThreadA 쓰레드가 동작합니다.");
+				try {
+					Thread.sleep(1000);
+				} catch (InterruptedException e) {
+					// TODO Auto-generated catch block
+					e.printStackTrace();
+				}
+			}
+			notify();
+		}
+	}
+	
+	public int getSum() {
+		return sum;
+	}
+}

src/kr/co/swh/lecture/java/scene4/ThreadHigh1Main.java

@@ -0,0 +1,39 @@
+package kr.co.swh.lecture.java.scene4;
+
+/**
+ * <pre>
+ * kr.co.swh.lecture.java.scene4
+ * ThreadHigh1Main.java
+ *
+ * 설명 : 쓰레드 고급 첫 번째 예제
+ * </pre>
+ * 
+ * @since : 2021. 12. 23.
+ * @author : tobby48
+ * @version : v1.0
+ */
+public class ThreadHigh1Main {
+	
+	
+	public static void main(String[] args) {
+		ThreadHigh1A threadA = new ThreadHigh1A();
+		threadA.start();
+		//	아래 주석코드를 풀고 다시 실행해보세요.
+//		try {
+//			Thread.sleep(100);
+//		} catch (InterruptedException e1) {
+//			// TODO Auto-generated catch block
+//			e1.printStackTrace();
+//		}
+		synchronized (threadA) {
+			System.out.println("ThreadA 가 완료될때까지 Wait...");
+			try {
+				threadA.wait();
+			} catch (InterruptedException e) {
+				// TODO Auto-generated catch block
+				e.printStackTrace();
+			}
+			System.out.println("5의 배수일때까지 합산은 : " + threadA.getSum());
+		}
+	}
+}

src/kr/co/swh/lecture/java/scene4/ThreadHigh1SecondMain.java

@@ -0,0 +1,45 @@
+package kr.co.swh.lecture.java.scene4;
+
+/**
+ * <pre>
+ * kr.co.swh.lecture.java.scene4
+ * ThreadHigh1SecondMain.java
+ *
+ * 설명 : 쓰레드 고급 첫 번째 예제
+ * </pre>
+ * 
+ * @since : 2021. 12. 23.
+ * @author : tobby48
+ * @version : v1.0
+ */
+public class ThreadHigh1SecondMain {
+	
+	
+	public static void main(String[] args) {
+		ThreadHigh1A threadA = new ThreadHigh1A();
+		threadA.start();
+		ThreadHigh1A threadA2 = new ThreadHigh1A();
+		threadA2.start();
+		synchronized (threadA) {
+			System.out.println("ThreadA 가 완료될때까지 Wait...");
+			try {
+				threadA.wait();
+			} catch (InterruptedException e) {
+				// TODO Auto-generated catch block
+				e.printStackTrace();
+			}
+			System.out.println("5의 배수일때까지 합산은 : " + threadA.getSum());
+		}
+		//	아래 코드에서 이상한 점은 없나요?
+		synchronized (threadA2) {
+			System.out.println("ThreadA 가 완료될때까지 Wait...");
+			try {
+				threadA2.wait();
+			} catch (InterruptedException e) {
+				// TODO Auto-generated catch block
+				e.printStackTrace();
+			}
+			System.out.println("5의 배수일때까지 합산은 : " + threadA.getSum());
+		}
+	}
+}

src/kr/co/swh/lecture/java/scene4/ThreadHigh2.java

@@ -0,0 +1,53 @@
+package kr.co.swh.lecture.java.scene4;
+
+/**
+ * <pre>
+ * kr.co.swh.lecture.java.scene4
+ * ThreadHigh2.java
+ *
+ * 설명 : 쓰레드 고급 두 번째 예제
+ * </pre>
+ * 
+ * @since : 2021. 12. 23.
+ * @author : tobby48
+ * @version : v1.0
+ */
+public class ThreadHigh2 extends Thread{
+	
+	private int sum = 0;
+	private ThreadHigh2SubJob otherThread;
+	
+	public ThreadHigh2(ThreadHigh2SubJob otherThread) {
+		// TODO Auto-generated constructor stub
+		this.otherThread = otherThread;
+	}
+	
+	@Override
+	public void run() {
+		// TODO Auto-generated method stub
+		synchronized(this){
+			for(int i=1; i<5; i++) {
+				sum += i;
+				System.out.println(i + "상위 쓰레드가 동작합니다.");
+				try {
+					Thread.sleep(1000);
+				} catch (InterruptedException e) {
+					// TODO Auto-generated catch block
+					e.printStackTrace();
+				}
+			}
+			try {
+				this.otherThread.join();
+			} catch (InterruptedException e) {
+				// TODO Auto-generated catch block
+				e.printStackTrace();
+			}
+			sum += this.otherThread.getSum();
+			notify();
+		}
+	}
+	
+	public int getSum() {
+		return sum;
+	}
+}

src/kr/co/swh/lecture/java/scene4/ThreadHigh2Main.java

@@ -0,0 +1,34 @@
+package kr.co.swh.lecture.java.scene4;
+
+/**
+ * <pre>
+ * kr.co.swh.lecture.java.scene4
+ * ThreadHigh2Main.java
+ *
+ * 설명 : 쓰레드 고급 두 번째 예제
+ * </pre>
+ * 
+ * @since : 2021. 12. 23.
+ * @author : tobby48
+ * @version : v1.0
+ */
+public class ThreadHigh2Main {
+	
+	
+	public static void main(String[] args) {
+		ThreadHigh2SubJob subThread = new ThreadHigh2SubJob();
+		subThread.start();
+		ThreadHigh2 threadA = new ThreadHigh2(subThread);
+		threadA.start();
+		synchronized (threadA) {
+			System.out.println("상위 가 완료될때까지 Wait...");
+			try {
+				threadA.wait();
+			} catch (InterruptedException e) {
+				// TODO Auto-generated catch block
+				e.printStackTrace();
+			}
+			System.out.println("1~10까지 합산은 : " + threadA.getSum());
+		}
+	}
+}

src/kr/co/swh/lecture/java/scene4/ThreadHigh2SubJob.java

@@ -0,0 +1,39 @@
+package kr.co.swh.lecture.java.scene4;
+
+/**
+ * <pre>
+ * kr.co.swh.lecture.java.scene4
+ * ThreadHigh2SubJob.java
+ *
+ * 설명 : 쓰레드 고급 두 번째 예제
+ * </pre>
+ * 
+ * @since : 2021. 12. 23.
+ * @author : tobby48
+ * @version : v1.0
+ */
+public class ThreadHigh2SubJob extends Thread{
+	
+	private int sum = 0;
+	
+	@Override
+	public void run() {
+		// TODO Auto-generated method stub
+		synchronized(this){
+			for(int i=5; i<11; i++) {
+				sum += i;
+				System.out.println(i + "하위 쓰레드가 동작합니다.");
+				try {
+					Thread.sleep(500);
+				} catch (InterruptedException e) {
+					// TODO Auto-generated catch block
+					e.printStackTrace();
+				}
+			}
+		}
+	}
+	
+	public int getSum() {
+		return sum;
+	}
+}

src/kr/co/swh/lecture/java/scene4/ThreadHigh3Main.java

@@ -0,0 +1,80 @@
+package kr.co.swh.lecture.java.scene4;
+
+/**
+ * <pre>
+ * kr.co.swh.lecture.java.scene4
+ * ThreadHigh3Main.java
+ *
+ * 설명 : 쓰레드 고급 생산자 소비자 모델
+ * </pre>
+ * 
+ * @since : 2021. 12. 23.
+ * @author : tobby48
+ * @version : v1.0
+ */
+public class ThreadHigh3Main {
+	public static void main(String[] args) {
+		WorkObject shareObject = new WorkObject(); 	//공유객체 생성
+
+		ThreadA threadA = new ThreadA(shareObject);
+		ThreadB threadB = new ThreadB(shareObject);	//ThreadA와 ThreadB 생성
+
+		threadA.start();
+		threadB.start();
+
+	}
+}
+//공유객체
+class WorkObject {
+	public synchronized void methodA() {
+		System.out.println("ThreadA의 methodA() 작업 실행");
+		notify(); 	//일시정지 상태에 있는 ThreadB를 실행대기 상태로 만듬.
+		try {
+			wait();	//ThreadA를 일시정지 상태로 만듬.
+		} catch (Exception e) {
+		}
+	}
+
+	public synchronized void methodB() {
+		System.out.println("ThreadB의 methodB() 작업 실행");
+		notify();	//일시정지 상태에 있는 ThreadA를 실행대기 상태로 만듬.
+		try {
+			wait();	//ThreadB를 일시정지 상태로 만듬.
+		} catch (Exception e) {
+		}
+	}
+}
+
+//Thread A
+class ThreadA extends Thread{
+	private WorkObject workObject;
+
+	public ThreadA(WorkObject workObject) {
+		this.workObject = workObject;
+	}
+
+	@Override
+	public void run() {
+		for(int i =0; i<10; i++) {
+			workObject.methodA();
+		}
+	}
+}
+
+//ThreadB
+class ThreadB extends Thread{
+	private WorkObject workObject;
+
+	public ThreadB(WorkObject workObject) {
+		this.workObject = workObject;
+	}
+
+	@Override
+	public void run() {
+		for(int i =0; i<10; i++) {
+			workObject.methodB();
+		}
+	}
+}
+
+