Blocking Method
블로킹 메서드는 다른 쓰레드로 제어권을 양도 하지 않고, 할당된 Task가 완료될 때까지 제어권을 넘겨주지 않으려 할 때 사용 하는 메서드 이다.Java에서 대표적인 블로킹 메소드는 InputStream 클래스의 read()와 ServerSocket 클래스의 accept()가 있다.
단점
- 블로킹 메서드의 단점 중 하나는 무한 대기에 빠질 수 있다는 점이다. 이로 인해 대기중인 다른 쓰레드가 살행되지 않는 경우가 생길 수 있다.Blocking I/O
- java에서 블로킹 소켓은 ServerSocket, Socket 두 가지 클래스를 사용한다.
- 클라이언트 연결 요청시 서버는 accept하고 클라이언트와 연결된 소켓을 새로 생성하는데 이 때 해당 메서드가 완료되기 전까지 스레드에 블로킹이 된다.
- 클라이언트가 연결된 소켓으로 서버에 데이터 전송시 서버는 read를 호출하고 다 읽을 때 까지 스레드가 블로킹 된다.
병렬처리 문제
- 데이터 입출력에서 스레드의 블로킹이 발생해 동시에 여러 클라이언트에 대한 처리가 불가하다.- 이를 해결위해 연결된 클라이언트 별로 각자 쓰레드를 할당하는 방법이 있다.
- 클라이언트 접속요청 오면 서버는 새로운 스레드를 하나 생성하고 클라이언트에게 I/O 처리를 넘겨준다.
- 동시 요청은 해결되었으나, 동시 접속으로 인한 스레드 생성, 할당, 제거하는 시간이 길어진다.
- 또한 계속되는 스레드 생성은 힙 메모리의 부족을 야기할 수 있다.
스레드 풀(Thread Pool)
- 스레드 증가로인한 메모리 부족을 피하기 위해 일정개수의 스레드를 풀에 미리 생성한다.- 클라이언트 요청이 들어오면 일단 작업 큐에 들어가게하고, 스레드 풀에서 스레드를 할당 받는다.
- 스레드풀 사용시 스레드 생성, 제거에 대한 오버해드가 사라지고 동시접속을 처리할 수있다.
- Java 에서는 java.util.concurrent.Executors에서 스레드 풀을 제공한다.
1) newFixedThreadPool
- parameter로 주어진 스레드 개수만큼 스레드를 생성하고, 애플리케이션 종료까지 유지한다.
2) newChachedThreadPool
- 처리할 작업이 많아지면 스레드를 증가하여 생성한다.
- 놀고있는 스레드가 많다면 해당 스레드를 종료한다.
- 스레드 개수를 유동적으로 조절. But 스레드가 많아지면 메모리 부족이 발생할 수도 있다.
3) newSingleThreadExecutor
- 스레드를 하나만 생성해 스레드가 비정상적으로 종료되면 하나의 스레드를 다시 생성한다.
4) newSheduledThreadPool
- 스레드와 관련된 작업을 특정 시간 이후에 실행되거나 주기적으로 작업을 실행할 수 있는 스레드 풀을 생성한다.
댓글
댓글 쓰기