reactor

2열

1답변

dev poll reactor에서 시간 초과를 구현하기 위해 linux timerfd를 사용합니다.

linux 용 timerfd (timerfd_create)를 사용하면 Timer_Heap 또는 Timer_Wheel보다 성능이 향상되는지 궁금합니다. 분명히 이것은 매우 높은 수준의 질문이며 모든 프레임 워크에서 사용되는 것을 본 유일한 곳은 "muduo"입니다. 또한 성능 비교도 없습니다. 감사합니다.

2열

1답변

ReactorNotRestartable 오류

네트워크에 연결된 장치의 upnp 검색을 구현하는 도구가 있습니다. 나는 스크립트를 작성하고 데이터 그램 클래스를 사용했다. 구현 : 도구에서 검색 버튼을 누를 때마다 해당 upnp 스크립트가 실행되고 도구에 생성 된 상자에 장치가 나열됩니다. 괜찮 았습니다. 하지만 난 다시 스캔 버튼을 누를 때, 그것은 나에게 다음과 같은 오류를 제공합니다 : Trace

0열

1답변

반응기가 단순히 반응하지 않습니다

reactor-core 1.1.4-RELEASE으로 시도했지만 아무 것도 출력되지 않았습니다. 나는 무엇을 놓쳐 야합니까? 아래 Reactor reactor = Reactors.reactor(new Environment()); reactor.on( $("hello"), (Event<String> ev) -> System.out.prin

2열

1답변

reactor-v1.x.x Vs reactor-v2.x.x

우리는 우리 프로젝트에서 그것을 사용하기 위해 원자로 라이브러리를 평가하고 있습니다. 우리 프로젝트는 봄에 뒷받침되었습니다. 그래서 우리는 스프링을 지원하는 이벤트 기반 응용 프로그램을 빌드하는 도구가 필요했습니다. 또한 우리의 주요 초점 영역은 비동기 이벤트 (스트림 & 약속)의 시퀀스 작성 능력에 관한 것이 었습니다. 특정 유스 케이스에서는 게시자/구독

0열

1답변

Popen 내부에서 (트위스트) timer.LoopingCall() 노점 ffmpeg을 실행

나는 HLS로 다시 스트리밍해야하는 RTSP 스트림이 있습니다. RTSP 스트림이 중단되면 (예 : 카메라 연결이 끊어짐) 사용자에게 카메라가 오프라인 상태임을 알리는 블루 스크린을 표시합니다. HLS 분할기가 별도로 실행되며 포트 22200에서 들어오는 패킷을 수신 대기합니다. 파이썬에서 코드는 기본적으로 다음과 같이 요약 될 수있다 : 5 ~ 6 분 동

0열

1답변

런타임에 리스너를 listenMulticast에 추가하거나 제거 할 때 twisted?

제목은 거의 그것을 설명한다; 가능합니까? master-backup 관계를 만들고 싶습니다. 여기서 마스터가 실패하면 백업이 인계되고 마스터가되어 자체 백업을 생성하여 실행을 계속합니다. 지금까지 방송하기 위해 listenMulticast을 사용하고 있습니다. 나는 학습 목적으로 터미널에 숫자가 증가하는 현상을 원합니다. 일종의 인터럽트 신호를 보내면 마스

0열

1답변

reactor.run()과 reactor.runReturn()의 차이점은 무엇입니까?

여기에 제가 제공 한 코드가 있습니다. 나는 runReturn의 기능이 무엇인지 잘 모릅니다. 문서가 약간 희박한 것처럼 보입니다. 나는 reactor.run()과 같지만 다른 곳으로 스레드 관리를 돌려 주겠습니까? app=QtGui.QApplication('monitor GUI') # Create the application app.setQuit

0열

1답변

Reactor 프레임 워크에서 맵 축소 작업을 어떻게 실행합니까?

Reactor 프레임 워크를 통해 맵/리덕션 작업을 수행하는 방법에 대한 코드 예제를 보여줄 수 있습니까? 내가 Collection<Map>이라고 가정 해 보겠습니다. 동시에 유형 Foo의 객체에 각 Map 인스턴스를 변환 (각 인스턴스는 서로 완전히 독립적 인 - 직렬/반복적으로 각각 변환 할 필요가 없습니다)에 전합니다. 모두 변환 될 때 onReduc

3열

1답변

twisted non-blocking은 reactor.run()을 실행합니까?

비 블록 읽기 소켓 입력에 꼬인 리액터를 사용하고 있습니다. 그러나, 나는 reactor.run() 후 while 루프가 작동하지 않는 것입니다 ..... reactor.listenTCP(12345, MyFactory()) reactor.run() # ... blah blah socket input related code while 1:

0열

1답변

이상한 포코 반응기 알림

에코 예제에서 설명한대로 Poco SocketReactor를 구현하는 코드가 있습니다. 또한 내가 그것을 테스트하는 파이썬 클라이언트가 Poco::Net::ServerSocket tcpsock("9495"); Poco::Net::SocketReactor reactor; Poco::Net::SocketAcceptor<TSPConnectionHandler>