석영 작업 스로틀

Question

작은 비트 정보 요구 사항 :

나는 데이터 수집기 ​​역할을하는 몇 개의 쿼츠 작업을 사용하며 가능한 경우 다른 위치에서 데이터를 수집합니다. 그런 다음 내 DB를 업데이트하기 위해 수집기 작업에서 호출 중이거나 트리거 된 다른 작업 [데이터로드]가 있습니다.

내 요구 사항은 (병렬로 실행되는 두 개의 인스턴스가 잡스 1, 2 집 작업

수집기에서 ... N> 로더 작업을 오는 작업을 처리하는 방법을 스로틀로드 작업 일부에 두 개의 인스턴스이다)

작업 프로그램은 클러스터 된 Tomcat에 배포됩니다.

두 가지 질문 : 1) Loader 작업의 두 인스턴스가 이미 처리 중이면 Collector 작업을 대기 상태로 만들 수 있습니까? Quartz 프로그램을 사용하여 FIFO 로직을 사용하여 작업을 Loader 작업으로 조절할 수 있습니까? 또한 이미 처리 대기중인 콜렉터가 다른 데이터를 가져 오지 않도록해야합니다. 2) 두 개의 스레드로만 작업을 실행할 수있는 방법이 있습니까? 한 번에 두 개 이상의 인스턴스가 활성화되어 있지 않아야합니까? 병렬로 두 개의 인스턴스 만 실행하려면 DB 테이블에 대한 제한이 있습니다.

Answer 1

생산자 - 소비자 상황이있는 것 같습니다. 일반적으로 제작자와 소비자는 대기열로 구분됩니다. 수집자에게 항목을 (영구?) 대기열에 넣고 Loader를 대기열에서 읽고 처리 스레드를 최대 2 개까지 처리하도록합니다.