자바에서 제공하는 큐(Queue) 인터페이스는 데이터를 선입선출(FIFO) 방식으로 관리할 수 있는 자료 구조를 제공합니다. 큐는 대기열과 같이 먼저 들어온 데이터가 먼저 나가는 구조로 사용됩니다. 이번에는 자바의 Queue 인터페이스를 사용하여 데이터를 처리하는 몇 가지 흥미로운 사례를 살펴보겠습니다.
1. 큐를 활용한 이벤트 처리
큐는 이벤트 처리에 유용하게 활용될 수 있습니다. 예를 들어, 사용자가 액션을 취하는 동안 발생하는 이벤트(마우스 클릭, 키보드 입력 등)를 큐에 순서대로 쌓아두고 처리할 수 있습니다.
import java.util.Queue;
import java.util.LinkedList;
public class EventQueue {
private Queue<Event> events = new LinkedList<>();
public void addEvent(Event event) {
events.add(event);
}
public void processEvents() {
while (!events.isEmpty()) {
Event event = events.poll();
// 이벤트 처리 로직
}
}
}
위의 코드는 LinkedList를 이용하여 이벤트를 순서대로 처리하는 간단한 예제입니다.
2. 멀티 스레딩 환경에서의 작업 배분
큐는 멀티 스레딩 환경에서 작업을 효율적으로 배분하는 데에도 활용될 수 있습니다. 여러 스레드에서 처리해야 하는 작업이 큐에 추가되고, 각 스레드가 큐에서 작업을 가져와 처리하는 방식으로 멀티 스레딩 환경을 구성할 수 있습니다.
import java.util.Queue;
import java.util.concurrent.LinkedBlockingQueue;
public class TaskQueue {
private Queue<Runnable> tasks = new LinkedBlockingQueue<>();
public void addTask(Runnable task) {
tasks.add(task);
}
public void processTasks() {
while (true) {
Runnable task = tasks.poll();
if (task != null) {
new Thread(task).start();
}
}
}
}
위의 코드는 LinkedBlockingQueue를 이용하여 멀티 스레딩 환경에서 작업을 배분하는 예제입니다.
3. 네트워크 프로그래밍에서의 메시지 큐
큐는 네트워크 프로그래밍에서 메시지 큐(Message Queue)로 활용될 수 있습니다. 서버에서 수신한 메시지를 큐에 넣고 순차적으로 처리하는 방식으로 여러 클라이언트 요청을 효율적으로 처리할 수 있습니다.
import java.util.Queue;
import java.util.concurrent.ArrayBlockingQueue;
public class MessageQueue {
private Queue<String> messages = new ArrayBlockingQueue<>(100);
public void addMessage(String message) {
messages.add(message);
}
public void processMessages() {
while (!messages.isEmpty()) {
String message = messages.poll();
// 메시지 처리 로직
}
}
}
위의 코드는 ArrayBlockingQueue를 이용하여 네트워크 프로그래밍에서 메시지를 처리하는 예제입니다.
결론
큐 인터페이스는 다양한 상황에서 데이터를 순서대로 처리하는 데에 유용하게 활용될 수 있습니다. 위에서 살펴본 예제들은 큐를 사용하여 이벤트 처리, 멀티 스레딩 환경에서의 작업 배분, 그리고 네트워크 프로그래밍에서의 메시지 큐 등 다양한 영역에서의 적용 사례를 보여줍니다. 이러한 다양한 활용을 통해 큐 인터페이스에 대한 이해를 높이고, 효율적인 데이터 처리를 할 수 있을 것입니다.
참고 문헌: Oracle Java Documentation