[JAVA]08-03.Priority, Synchronized

1.Priority

Thread에 우선순위를 부여하여 실행하는 것이다.

너무 짧은 작업이라면 우선순위 부여에 의미가 없지만 작업이 커질수록 차이가 느껴질 것이다.

package chap10.exam04.priority;

public class WorkThread extends Thread {

	public WorkThread() {
		// TODO Auto-generated constructor stub
	}

	public WorkThread(String name) {
		setName(name);
	}

	@Override
	public void run() {
		System.out.println(getName() + "의 작업 시작");
		for(int i = 0; i < 100000; i++) {
			// 이 시간동안 작업이 있다고 가정
		}
		System.out.println(getName() + "의 작업 끝");
	}

}

package chap10.exam04.priority;

public class Main {

	public static void main(String[] args) {
		// 우선 순위는 1~10까지 줄 수 있다.
		// 우선 순위가 같거나 없으면 무조건 빠른놈이 먼저다.
		// 우선 순위는 상수로도 가능하다.
		
		for(int i = 1 ; i <= 5; i++) {
			Thread th = new WorkThread(i + "번째 스레드");
			th.setPriority(i);
//			th.setPriority(Threa[d.MAX_PRIORITY);
//			th.setPriority(Thread.MIN_PRIORITY);
//			th.setPriority(Thread.NORM_PRIORITY);
			th.start();
			try {
				Thread.sleep(500);
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			// 우선순위만으로는 완벽한 스레드 제어가 어렵다
		}
	}

}

2.Synchronized

Thread는 메모리를 공유하는 특성이 있기 때문에 데이터의 간섭이 일어날 수 있다.

두 개의 thread가 돌아갈 때에 같은 데이터를 수정한다면 작업의 순서도 예측하기 어렵고 값이 어떻게 바뀔지도 모르게 된다.

Synchronized는 코드를 { }괄호로 감싸서 thread가 그 부분을 읽을 때 다른 thread에서 읽지 못하게 잠궈버린다.

먼저 들어온 thread가 작업을 마치고 다음 thread가 작업을 실행하게 된다.

package chap10.exam05.sync;

public class Computer {
	private int score;

	// 동기화 이전
	//	public void setScore(int score) {
	//		this.score = score;
	//		try {
	//			Thread.sleep(2000); // 2초 슬립 (이 사이 다른 사용자가 정보 변경 가능)
	//		} catch (InterruptedException e) {
	//			// TODO Auto-generated catch block
	//			e.printStackTrace();
	//		} 
	//		System.out.println(Thread.currentThread().getName() + " : " + this.score);
	//	}

	// 동기화 메소드 방식 : 메소드 접근을 제한
	//	public synchronized void setScore(int score) {
	//		this.score = score;
	//		try {
	//			Thread.sleep(2000); // 2초 슬립 (이 사이 다른 사용자가 정보 변경 가능)
	//		} catch (InterruptedException e) {
	//			// TODO Auto-generated catch block
	//			e.printStackTrace();
	//		} 
	//		System.out.println(Thread.currentThread().getName() + " : " + this.score);
	//	}

	// 동기화 블록 방식 : 메소드 까지는 허용, 특정 구역에서 제한

	public void setScore(int score) {
		// 스레드 들이 들어와서 작동할 수 잇음
		synchronized (this) { // this는 현재 Computer 객체
			this.score = score;
			try {
				Thread.sleep(2000); // 2초 슬립 (이 사이 다른 사용자가 정보 변경 가능)
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			} 
			System.out.println(Thread.currentThread().getName() + " : " + this.score);
		}
	}
}

package chap10.exam05.sync;

public class User1 extends Thread{
	private Computer com;
	public User1(Computer com) {
		setName("user 1");
		this.com = com;
	}
	@Override
	public void run() {
		com.setScore(500); // user 1은 점수를 500으로 만든다.
	}
	

}

package chap10.exam05.sync;

public class User2 extends Thread {
	private Computer com;
	
	public User2(Computer com) {
		setName("user 2");
		this.com = com;
	}

	@Override
	public void run() {
		com.setScore(100); // user2는 점수를 100으로 만든다.
	}

}

package chap10.exam05.sync;

public class PcRoom {

	public static void main(String[] args) {
		// 공용 컴퓨터 만들기
		Computer com = new Computer();
		//user1에게 컴 사용 하게 해줌
		User1 user1 = new User1(com);
		user1.start();
		//user2에게 컴 사용 하게 해줌
		User2 user2 = new User2(com);
		user2.start();
	}

}