여러 제조업체, 하나의 소비자 : 기아 없어 짐

Question

여러 생산자가 단일 소비자에게 메시지를 보내는 생산자 - 소비자 문제의 예가 나타납니다. 일부 메시지가 도착하면 생산자 기아를 피하기 위해 어떤 기술을 권장합니까 "동시에"소비자에게. 지금까지 내가 고려하고 :

1. 을 (메시지의 다른 번호가 서로 다른 시간 스탬프에 도착하는 것을 어떻게 생각 확실하지) 몇 가지 확률 분포를 샘플링하여 "비 확정적"선택.
2. 일부 카운터를 사용하여 n 개의 메시지를 보낸 후 잠시 동안 잠자기 상태로 만듭니다.

Answer 1

가장 간단한 방법 중 가장 좋은 방법은 메시지를 도착 순서대로 처리하는 것입니다 (간단한 FIFO 목록이 트릭을 수행합니다). 동시에 여러 메시지가 오더라도 상관 없습니다. 이런 식으로 생산자 중 누구도 굶어 죽지 않을 것입니다.

소비자가 메시지를 생산하는 생산자보다 더 빨리 메시지를 소비한다는 것이 한 가지 확실한 사실입니다. 그렇게하지 않으면 소비자를 기다리는 생산자가 끝날 수 있으며 단일 소비자를 위해 여러 생산자를 갖는 것에 어떤 이점도 없습니다.

Answer 2

우선 순위 큐를 사용할 수 있다면 각 제작자는 메시지를 보낸 카운터를 가질 수 있다고 생각합니다. 그리고 큐는 messageSent 번호와 날짜에 따라 순서가 정해 지므로 전송 된 번호가 다른 메시지보다 작 으면 다른 메시지보다 먼저 메시지를 보내야합니다. 프로듀서 1 (첫번째) 큐에 5 개 요소를 추가하고 프로듀서 2 일 추가하는 경우 자바에서

class Message { //or you can implement Comparable<Message> 
    final Date created = new Date(); 
    final int messageNumber; 
    public Message(int m){this.messageNumber = m;} 
} 
BlockingQueue<Message> queue = new PriorityBlockingQueue<Message>(new Comparator(){ 
    public int compare(Message m1, Message m2){ 
     if(m1.messageNumber < m2.messageNumber) return 1; 
     if(m2.messageNumber < m1.messageNumber) return -1; 
     if(m1.messageNumber == m2.messageNumber) return m1.created.compareTo(m2.created); 
    } 
}); 
class Provider{ 
    int currentMessage = 0; 
    void send(){ 
     queue.offer(new Message(currentMessage++)); 
    } 
} 

그래서, 큐는 뮤텍스 구현을 상상하기

P1: 5 
P1: 4 
P1: 3 
P1: 2 
P2: 1 
P1: 1