producer-consumer

0열

2답변

파이썬 프로세스 간 큐 오버플로

나는 N 개의 소비자로 구성된 프로듀서를 가지고있다. 생산자는 대량의 TCP 메시지 (1 분당 10,000 개)를 수신하는 소켓을 청취하고,이 데이터를 읽고이를 작업자를위한 대기열에 넣습니다. iterations = 0 work_iterations = 0 while True: try: iterations += 1 data =

python queue producer-consumer interprocess 2013-07-29

---

1열

2답변

Rx Pub/Sub 패턴에서 시퀀스를 생성하는 방법

Rx를 사용하여 Pub/Sub 패턴 (즉, 다음 요소가 제작자가 게시 한 클래식 관찰자 패턴)에서 시퀀스를 생성하는 것을 평가하려고합니다. . 이것은 기본적으로 .net 이벤트와 동일하지만 이벤트가 필요하지 않도록 일반화해야한다는 점을 제외하고는 Observable.FromEvent를 활용할 수 없습니다. Observable.Create 및 Observab

c# .net system.reactive publish-subscribe producer-consumer 2013-07-31

---

1열

3답변

스칼라에 선물이있는 프로듀서 - 소비자

생산자가 소비자에게 메시지를 보내고 소비자가 스칼라 Futures을 사용하여 비동기로 메시지를 처리하는 경우를 예로 들어 봅니다 (예 : future { /* do the processing */ }). 이제 프로듀서가 초당 100 개의 메시지를 생성한다고 가정 해 보겠습니다. 소비자는 초당 10 개의 메시지 만 처리합니다. 무슨 일이 일어날 것 ? 나는

scala concurrency future producer-consumer 2013-08-06

---

0열

4답변

Java 생성자 소비자 완료 알림이있는 소비자 패턴

여러 제작자와 단일 소비자가있는 생산자/소비자 시나리오를 구현하고 싶습니다. 제작자는 항목을 대기열에 계속 추가하고 소비자는 항목을 대기열에서 제외합니다. 소비자가 충분한 항목을 처리하면 생산자와 소비자 모두 실행을 중지해야합니다. 소비자는 충분한 항목을 처리 할 때 쉽게 종료 될 수 있습니다. 그러나 생산자는 언제 퇴출해야 하는지도 알아야합니다. 전형적인

java multithreading producer-consumer 2013-06-18

---

0열

3답변

제 제작자 소비자 프로그램이 차단하는 이유는 무엇입니까?

내 대기열을 만들었습니다. Queue.java public class MyQueue { private int size; private Queue<String> q; public MyQueue(int size ,Queue<String> queue) { this.size = size; this.q = queue

java multithreading producer-consumer 2013-08-10

---

0열

4답변

2 개의 스레드에 대해 하나의 Runnable을 사용하여 하나가 생성되고 하나가 소비되도록 할 수 있습니까?

아래 코드에서 Thread t1이 Runnable 생성을 실행하고 Thread t2가 Runnable 실행을 실행하도록합니다. 이게 효과가 있니? class Processor implements Runnable { @override run(){ produce(); consume(); } void pr

java multithreading producer-consumer 2013-06-24

---

3열

1답변

Apache Camel 및로드 균형 조정

Camel을 사용하여 일부 외부 시스템 (FTP, SOAP-WS, REST-WS, 주제, 대기열 등) 간의 통합을 계획합니다. 우리는 Spring 구성 (Camel 컨텍스트 XML)을 사용하고 정보량이 크기 때문에 Tomcat 클러스터에 배포 할 계획입니다. 가능 한 구성이고 두 응용 프로그램 (시작 부분에 두 개의 바람둥이가 있다고 말하면)이 간섭 할 수

apache-camel cluster-computing load-balancing producer-consumer 2013-06-27

---

1열

1답변

생산자 - 소비자 및 데이터베이스 대기열

나는 생산자 소비자 메커니즘을 가지고 있습니다. 나는 데이터베이스에 생산 된 상품을 저장해야합니다. 이것은 필수 사항입니다. 또한 여러 제작자와 여러 소비자, 생산자 및 소비자 스레드가 여러 데이터베이스 테이블의 레코드에 액세스합니다. ProcessID 열은 어떤 스레드가 어떤 레코드에 액세스하고 있는지를 결정합니다. 스레드는 Windows 서비스를 통해

multithreading architecture thread-safety producer-consumer database-locking 2013-07-02

---

0열

1답변

분산 된 소비자에게 주어진 시간에 N 개 이상의 메시지를 큐에서 보낼 수 있습니까?

RabbitMQ에서 메시지를 읽는 분산 시스템이 있습니다. 내 상황에서는 이제 N msgs/s 이상을 처리해야합니다. 예 : 문자 메시지 (SMS)를 보내는 서비스 A을 상상해보십시오. 이 서비스는 100 개의 msgs만을 처리 할 수 ​​있습니다. 내 시스템에는 RabbitMQ에서 데이터를 읽는 여러 소비자가 있습니다. 각 메시지는 먼저 처리되어야하며 서

queue rabbitmq producer-consumer pika 2013-07-13

---

1열

1답변

프로듀서 - 로컬 소비자 용 ExecutorService 인 프로듀서 - 소비자

원격 메시지 큐가 새 작업 메시지와 로컬 ExecutorService에 대해 주기적으로 폴링되어야하는 생산자 - 소비자 상황이 있습니다. 작업을 실행합니다. MQ를 폴링하는 많은 작업 실행자가 있습니다. 로컬 executor는 처리량이 상대적으로 고정 된 고정 수의 스레드를 갖습니다. 문제는 비록 내가 그들을 처리 할 수없는 경우 원격 메시지를 소비하는 단

java executorservice producer-consumer future 2013-07-16

---