- 전체
- JAVA 일반
- JAVA 수학
- JAVA 그래픽
- JAVA 자료구조
- JAVA 인공지능
- JAVA 인터넷
- Java Framework
- Java GUI (AWT,SWING,SWT,JFACE)
- SWT and RCP (web RAP/RWT)[eclipse], EMF
JAVA 일반 Java 세마포어(Semaphore)
2013.12.11 14:53
[출처] http://snowbora.tistory.com/472
[Java] 세마포어(Semaphore)에 대해서
멀티 쓰레드(Multi-Thread) 프로그래밍을 할 때, 한정된 리소스(Resource)를 각 쓰레드들에게
분배해야 하는 경우가 있습니다.
예를 들어, 쓰레드 개수가 10개인데 리소스 개수가 3개밖에 없는 경우 쓰레드 3개만 일단 돌리고
나머지 7개는 대기하고 있다가 리소스가 해제되는 즉시, 대기하고 있던 쓰레드들 중에서 하나가
그 리소스를 차지하고 실행하게 됩니다. 쓰레드풀 같은 경우도 비슷한 원리이죠.
어떻게 생각하면 동시에 작동할 수 있는 쓰레드의 개수를 조정한다고 생각할 수도 있는데... (엄밀히 따지면 다르지만)
이렇게 한정된 자원의 분배 및 정리를 위해 세마포어(Semaphore)를 사용할 수 있습니다.
세마포어를 이용한 간략한 예제는 다음과 같습니다.
(역시나 제가 공부하고 있는 교재에서 인용했습니다.)
이와 같이 new Semaphore(nCount); 를 이용해서 동시에 사용할 수 있는 리소스의 개수를 정해두고
Semaphore.acquire(); 로 리소스를 확보하고
Semaphore.release(); 로 리소스를 반환하면 됩니다.
분배해야 하는 경우가 있습니다.
예를 들어, 쓰레드 개수가 10개인데 리소스 개수가 3개밖에 없는 경우 쓰레드 3개만 일단 돌리고
나머지 7개는 대기하고 있다가 리소스가 해제되는 즉시, 대기하고 있던 쓰레드들 중에서 하나가
그 리소스를 차지하고 실행하게 됩니다. 쓰레드풀 같은 경우도 비슷한 원리이죠.
어떻게 생각하면 동시에 작동할 수 있는 쓰레드의 개수를 조정한다고 생각할 수도 있는데... (엄밀히 따지면 다르지만)
이렇게 한정된 자원의 분배 및 정리를 위해 세마포어(Semaphore)를 사용할 수 있습니다.
세마포어를 이용한 간략한 예제는 다음과 같습니다.
(역시나 제가 공부하고 있는 교재에서 인용했습니다.)
02.
03.
import
java.util.Random;
04.
import
java.util.concurrent.Semaphore;
05.
06.
class
Log
07.
{
08.
public
static
void
show(String strMessage)
09.
{
10.
System.out.println(Thread.currentThread().getName() +
" : "
+ strMessage);
11.
}
12.
}
13.
14.
class
BoundedResource
15.
{
16.
private
final
Semaphore m_Semaphore;
17.
private
final
int
m_nPermits;
18.
private
final
static
Random m_Random =
new
Random(10000);
19.
20.
public
BoundedResource(
int
nCount)
21.
{
22.
this
.m_Semaphore =
new
Semaphore(nCount);
23.
this
.m_nPermits = nCount;
24.
}
25.
26.
public
void
use()
throws
InterruptedException
27.
{
28.
m_Semaphore.acquire();
// 세마포어 리소스 확보
29.
try
30.
{
31.
doUse();
32.
}
33.
finally
34.
{
35.
m_Semaphore.release();
// 세마포어 리소스 해제
36.
}
37.
}
38.
39.
protected
void
doUse()
throws
InterruptedException
40.
{
41.
/*
42.
m_nPermits - m_Semaphore.availablePermits()
43.
= 최대 Resource 개수 - 세마포어에서 이용가능한 Resource 개수
44.
= 현재 사용중인 Resource 개수
45.
*/
46.
Log.show(
"Begin : 현재 사용중인 Resource 개수 = "
+ (m_nPermits - m_Semaphore.availablePermits()));
47.
Thread.sleep(m_Random.nextInt(500));
48.
Log.show(
"End : 현재 사용중인 Resource 개수 = "
+ (m_nPermits - m_Semaphore.availablePermits()));
49.
}
50.
}
51.
52.
class
UserThread
extends
Thread
53.
{
54.
private
final
static
Random m_Random =
new
Random(10000);
55.
private
final
BoundedResource m_resource;
56.
57.
public
UserThread(BoundedResource resource)
58.
{
59.
m_resource = resource;
60.
}
61.
62.
public
void
run()
63.
{
64.
try
65.
{
66.
while
(
true
)
67.
{
68.
m_resource.use();
69.
Thread.sleep(m_Random.nextInt(3000));
70.
}
71.
}
72.
catch
(InterruptedException e) {}
73.
}
74.
}
75.
76.
public
class
Main
77.
{
78.
public
static
void
main(String[] argc)
79.
{
80.
System.out.println(
"Starting..."
);
81.
BoundedResource resource =
new
BoundedResource(3);
82.
83.
// 10개의 Thread가 생성되어 있지만, 동시에 resource를 사용할 수 있는
84.
// Thread는 총 3개뿐임
85.
for
(
int
i=0; i<10; i++)
86.
{
87.
new
UserThread(resource).start();
88.
}
89.
90.
}
91.
}
Semaphore.acquire(); 로 리소스를 확보하고
Semaphore.release(); 로 리소스를 반환하면 됩니다.
본 웹사이트는 광고를 포함하고 있습니다.
광고 클릭에서 발생하는 수익금은 모두 웹사이트 서버의 유지 및 관리, 그리고 기술 콘텐츠 향상을 위해 쓰여집니다.
광고 클릭에서 발생하는 수익금은 모두 웹사이트 서버의 유지 및 관리, 그리고 기술 콘텐츠 향상을 위해 쓰여집니다.