다중 센서와 통신하기위한 다중 스레드

Question

새로운 스레드입니다. 여러 분의 센서와 매 순간 1 분마다 연중 무휴로 계속 통신하고 싶습니다.

Senario는 : 나는 방법은 3 개 인수

public String perform(String command, String ip, String port) 
{ 
    //talk to the sensor and then 
    returns reply; 
} 

내가 센서의 세부 사항을 포함하는 데이터베이스가 소요 센서 이야기해야합니다.

내가 지금하고 있어요

while(true) 
{ 
    //get sensors from database 

    //run perform method for all instruments 
    for(int i=0;i<sensors.length-1;i++) 
    { 
    //call perform method and save the reply 
    } 
    Thread.sleep('one minute'); 
} 

문제 : (100 개) 센서가 각 센서는 그 후 다음 답장을 1 초 걸리는 경우 문제는 내가 1 기다리고있을 것입니다 이 경우 일부 정보가 손실 될 수 있습니다. 솔직히 말해서 응답하는 데 1 초 이상 걸립니다.

내가 원하는 것은이며 모든 센서에 대해 데이터베이스에서 정보를 얻습니다. 다음 각 센서에 대해 하나의 스레드를 만듭니다. 그런 다음 모든 스레드를 한 번에 실행하면 정보가 반환됩니다. 그 후에 1 분을 기다린 다음 다시 시도하십시오.

도움을 주시면 감사하겠습니다.

감사

Answer 1

당신은 ScheduledThreadPoolExecutor 봤어?

간단한 사용법은 각 센서에 대해 Callable을 만들고 센서가있는 수만큼의 스레드를 포함하도록 스레드 풀을 구성하는 것입니다. 그런 다음 각 호출 가능 프로그램을 제출하고 적절한 스케줄을 지정하십시오.

이 접근법은 특별히 정확한 타이밍을 보장하지 않는다는 것을 유의하십시오 (자바는 실시간 플랫폼이 아닙니다). 다른 문제는 많은 스레드를 생성하는 것이 상대적으로 메모리를 많이 차지할 수 있다는 것입니다 (스레드 당 표준 힙 할당은 512k이지만 IIRC는 구성 가능합니다). 1000s 센서가있는 경우이 방법은 확장되지 않습니다.

Answer 2

개인적으로 나는 다른 접근 방식을 취할 것입니다. 서버가 항상 RESTful API를 통해 수신 대기 한 다음 센서가 매분 (또는 다른 간격을 결정할 때마다) POST 상태가되도록합니다. 이렇게하면 서버와 센서가 동일한 JVM 내에있을 필요가 없으며 IMHO가 확장 가능합니다. 또한이 방법으로 모든 센서는 서버의 다른 RESTful API를 통해 다른 센서의 상태를 쿼리 할 수 ​​있습니다.

또한 서버는 각 POST를 처리하기 위해 스레드를 시작할 수 있으며 한 센서가 매우 오래 걸리면 나머지는 차단되지 않습니다.