- 전체
- 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 Log07.{08. public static void show(String strMessage)09. {10. System.out.println(Thread.currentThread().getName() + " : " + strMessage);11. }12.}13. 14.class BoundedResource15.{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 InterruptedException27. {28. m_Semaphore.acquire(); // 세마포어 리소스 확보29. try30. {31. doUse();32. }33. finally34. {35. m_Semaphore.release(); // 세마포어 리소스 해제36. }37. }38. 39. protected void doUse() throws InterruptedException40. {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 Thread53.{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. try65. {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(); 로 리소스를 반환하면 됩니다.
본 웹사이트는 광고를 포함하고 있습니다.
광고 클릭에서 발생하는 수익금은 모두 웹사이트 서버의 유지 및 관리, 그리고 기술 콘텐츠 향상을 위해 쓰여집니다.
광고 클릭에서 발생하는 수익금은 모두 웹사이트 서버의 유지 및 관리, 그리고 기술 콘텐츠 향상을 위해 쓰여집니다.
