Embedded Files
https://m.blog.naver.com/qbxlvnf11/220945432938
동영상 파일을 일시 정지 하려면 해당 스레드를 일시 정지 해야만 하고, 동영상 파일을 종료 하려면 해당 스레드를 종료 해야만 합니다. 이와 같이 실행 중인 스레드 상태를 변경하는 것을 스레드 상태 제어라고 합니다.
멀티 스레드를 프로그램에서 하나의 스레드라도 잘못되면 전체 프로그램이 망가질 수 있기 때문에 어떻게 스레드 상태를 관리할까는 매우 중요한 문제입니다.
- 주어진 시간동안 일시 정지(sleep())
실행 중인 스레드를 일정 시간 멈추게 하고 싶다면 Thread 클래스의 sleep() 메소드를 사용하면 됩니다. Thread.sleep()메소드를 호출한 스레드는 주어진 시간 동안 일시 정지 상태가 되고, 다시 실행 대기 상태로 돌아갑니다.
sleep()의 매개값에는 얼마 동안 일시 정지 상태로 있을 것인지, 밀리세컨드(1/1000) 단위로 시간을 주면 됩니다. 예를 들어, Thread.sleep(3000)이면, 해당 스레드는 3초가 경과할 동안 일시 정지 상태로 있게 됩니다.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
import java.awt.Toolkit;
public class SleepThread {
public static void main(String []args){
Toolkit toolkit = Toolkit.getDefaultToolkit();
for(int i=0; i<10; i++){
toolkit.beep();
System.out.println("3초 기다리세요.");
try {
Thread.sleep(3000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
위의 sleep 예제를 실행시키면, 3초마다 스레드가 정지 상태가 되므로 3초 주기로 beep음이 들리게 됩니다. sleep()에 예외 처리가 되어 있는데, 이는 일시 정지 상태에서 주어진 시간이 되기 전에 interrupt() 메소드가 호출되어 InterruptedException이 발생하기 때문입니다. 여기서 interrupt()는 일시 정지 상태의 스레드에서 InterruptedException 예외를 발생시켜, 예외 처리 코드(catch)에서 실행 대기 상태로 가거나 종료 상태로 갈 수 있도록 하는 메소드입니다.
- 다른 스레드에게 실행 양보(yield())
스레드가 처리하는 작업은 반복적인 실행을 위해 반복문을 포함하는 경우가 많습니다. 가끔은 이 반복문들이 무의미한 반복을 하는 경우가 있습니다. 다음 코드를 봐주세요.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
class ThreadA extends Thread{
boolean flag;
public void setFlag(boolean flag) {
this.flag = flag;
}
public void run(){
while(true){
if(flag){
System.out.println("ThreadA is working..");}
}
}
}
flag의 값이 true일 때, 스레드가 시작되어 run() 메소드를 실행하면 while(){} 블록을 무한 반복 하게 됩니다. 만약 도중에 flag의 값이 false로 변하게 된다면 while문은 어떠한 동작도 하지 않기 때문에, 해당 스레드는 또한 아무 동작을 하지 않습니다. 스레드 스케줄링(Thread Scheduling) 도중, 이런 동작을 하지 않는 스레드가 존재할 때, 이 스레드를 실행하는 것보다 다른 동작을 하는 스레드를 실행 시키고, 동작을 하지 않는 스레드는 실행 대기 상태로 가는 것이 전체 프로그램 성능에 도움이 됩니다.
이런 기능을 위해서 스레드는 Thread.yield() 메소드를 제공하고 있습니다. yield() 메소드를 호출한 스레드는 실행 대기 상태로 돌아가고 동일한 우선순위 또는 높은 우선순위를 갖는 다른 스레드가 실행 기회를 가질 수 있도록 해줍니다.
다음은 yield() 메소드를 사용한 예제입니다.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
package package1;
class ThreadA extends Thread{
private boolean stop = false;
private boolean flag = true;
public void setFlag(boolean flag){
this.flag=flag;
}
public void setStop(boolean stop){
this.stop=stop;
}
public void run(){
while(!stop){
if(flag){
System.out.println("ThreadA is working..");
}
else{
// flag가 false가 되면 다른 스레드에게 실행 양보
Thread.yield();
}
}
}
}
class ThreadB extends Thread{
private boolean stop = false;
private boolean flag = true;
public void setFlag(boolean flag){
this.flag=flag;
}
public void setStop(boolean stop){
this.stop=stop;
}
public void run(){
while(!stop){
if(flag){
System.out.println("ThreadB is working..");
}
else{
// flag가 false가 되면 다른 스레드에게 실행 양보
Thread.yield();
}
}
}
}
public class this_test {
public static void main(String[]args){
ThreadA threadA = new ThreadA();
ThreadB threadB = new ThreadB();
// Thread A, B 시작
threadA.start();
threadB.start();
try {
Thread.sleep(2000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
// Thread B만 실행
threadA.setFlag(false);
try {
Thread.sleep(2000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
// Thread A만 실행
threadA.setFlag(true);
threadB.setFlag(false);
try {
Thread.sleep(2000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
// Thread 종료
threadA.setStop(true);
threadB.setStop(true);
}
}
- 다른 스레드의 종료를 기다림(join())
스레드는 다른 스레드와 독립적으로 실행하는 것이 기본이지만 다른 스레드가 종료될 때까지 기다렸다가 실행해야 하는 경우가 발생할 수 있습니다. 예를 들어 계산 작업을 하는 스레드가 모든 계산 작업을 마쳤을 때, 계산 결과값을 받아 이용하는 경우가 이에 해당합니다. 계산 작업이 완료가 안됬는데 결과값을 받아오면 문제가 생기겠죠?? 이런 경우를 위해서 Thread.join() 메소드를 제공하고 있습니다.
ThreadA가 ThreadB의 join() 메소드를 호출하면 ThreadA는 ThreadB가 종료할 때까지 일시 정지 상태가 됩니다. ThreadB의 run() 메소드가 종료되면 비로소 ThreadA는 일시 정지에서 풀려 다음 코드를 실행하게 됩니다.
다음 join()을 쓰지 않은 예제와 join()을 쓴 예제를 비교해봅시다.
▶ join을 쓰지 않은 예제
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
package package1;
class SumThread extends Thread{
private long sum;
public long getSum(){
return sum;
}
public void run(){
for(int i=1; i<=1000; i++){
sum+=i;
}
}
}
public class JoinExample {
public static void main(String []args){
SumThread sumThread = new SumThread();
sumThread.start();
System.out.println("sum: "+sumThread.getSum());
}
}
▶ 결과
계산 작업을 모두 마치기 전에 계산결과를 도출해서 결과값이 0으로 나온 것을 알 수 있습니다.
▶ join을 쓴 예제
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
package package1;
class SumThread extends Thread{
private long sum;
public long getSum(){
return sum;
}
public void run(){
for(int i=1; i<=1000; i++){
sum+=i;
}
}
}
public class JoinExample {
public static void main(String []args){
SumThread sumThread = new SumThread();
sumThread.start();
try {
sumThread.join();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
System.out.println("sum: "+sumThread.getSum());
}
}
▶ 결과
메인 스레드는 SumThread가 계산 작업을 모두 마칠 때까지 일시 정지 상태에 있다가 SumThread가 최종 계산된 결과값을 산출하고 종료하면 결과값을 받아 출력합니다.
Page updated
Google Sites
Report abuse