멀티 스레딩 ArrayList 반복

Question

인사말!

Java (JavaFX8)에서 간단한 서버 모니터링 응용 프로그램을 작성했습니다. 현재 구현에서는 대상 머신을 하나씩 핑 (ping)하여 JavaFX LineChart에 그래프로 표시 할 수 있습니다. 각 기계는 ArrayList (Observable)에있는 "대상"객체입니다. 내 문제는 "하나씩"부분입니다. 대상을 ping하는 코드는 ping을 반환하는 Callable입니다. 필자는 어쨌든 한 번에 4 개 이상의 대상에 대해 ping을 수행 할 수 있도록 프로세스를 다중 스레드해야합니다. 과거의 시도로 인해 동일한 대상을 동시에 핑하는 4 개의 스레드와 같은 단점이 발생하여 매우 중요한 프로세서 중복이 발생했습니다. Heres는 내 전류 루프는 ...

public void beginPing() { 
    ExecutorService exec = Executors.newCachedThreadPool(); 

    Runnable r = new Runnable() { 
     @Override 
     public void run() { 
      while (true) { 
       for (Target t : targets) { 
        String ping = null; 
        if (t.flagsProperty().get().contains("A")) { 
         try { 
          Callable c = new Pinger(t); 
          ping = c.call().toString(); 
          switch (ping) { 
           case "TIME_OUT": 
            for (XYChart.Series s : lineChart.getData()) { 
             if (s.getName().equals(t.nameProperty().get())) { 
              addToChart(s, cycle, 00.00); 
             } 
            } 
            t.setStatus("TIME OUT"); 
            t.setLastrtt("TIME_OUT"); 
            t.setTimeouts(t.timeoutsProperty().get() + 1); 
            logUtil.log(LogUtil.INFO, t.nameProperty().get() + " - timed out!"); 
            break; 
           case "UNKNOWN_HOST": 
            t.setStatus("ERROR"); 
            t.setLastrtt("UNKNOWN HOST"); 
            logUtil.log(LogUtil.WARNING, t.nameProperty().get() + " - unknown host!"); 
            break; 
           case "UNREACHABLE": 
            t.setStatus("ERROR"); 
            t.setLastrtt("UNREACHABLE HOST"); 
            logUtil.log(LogUtil.WARNING, t.nameProperty().get() + " - is unreachable!"); 
            break; 
           default: 
            t.setLastrtt(ping); 
            t.setStatus("ACTIVE"); 
            for (XYChart.Series s : lineChart.getData()) { 
             if (s.getName().equals(t.nameProperty().get())) { 
              addToChart(s, cycle, Double.valueOf(ping)); 
             } 
            } 
            break; 
          } 
         } catch (Exception e) { 
          logUtil.log(LogUtil.CRITICAL, e.getMessage() + ", "+ e.getCause()); 
          e.printStackTrace(); 
         } 
        } 
       } 
       cycle++; 
       rangeChart(cycle); 
       updateInfo(); 
      } 
     } 
    }; 
    exec.execute(r); 
} 

Answer 1

내 느낌은 어떤 멀티 스레딩 서비스를 구현하지 않는 경우에만 인터페이스하지만 당신이, 일반 클래스처럼 호출 가능 클래스 Pinger의 오용이다. 이 같은 이상을 보여야하고 싶은 것은 :

이

//init 
Future<String> futures = new Future[targets.length]; 
String results = new String[targets.length]; 
ExecutorService service = Executors.newCachedThreadPool(); 

//start Threads 
for (int i = 0; i<targets.length; i++){  
    Pinger pinger= new Pinger(targets[i]); 
    future[i] = service.submit(pinger); 
} 

//wait for Threads to finish and get results 
for(int i = 0; i<futures.length; i++) 
    results[i] = futures[i].get() 

귀하의 Pinger의는 다음과 같아야합니다

public class Pinger implements Callable<String>{ 
    Pinger(Target target){ ... } 
    public String call(){ ... } 
} 

여기 당신이 완전히 구현 Example for Callables을 찾을 수 있습니다. 귀하의 코드에서 오직 하나의 Runnable을 ExecutorService에 제출하기 때문에 오직 두 개의 스레드 (Main과 Runnable) 만있을 것입니다. 당신은 결코 call() 메소드를 호출하지 않는다. 이것은 ExecutorService에 의해 수행된다. 이것을 Runnable Interface와 비교해 보면 Thread 호출 시작을 실행하거나 run()을 호출하는 대신 ExecutorService에 제출해야합니다. submit() 중에 반환되는 Future를 사용합니다. Callable의 개념을 이해하려고 시도하면 원하는 모든 것을 쓸 수 있습니다. ;-)

Answer 2

따라서, heres는 현재 작업 구현 ...

public void beginPing() { 
    safeTargets = new ArrayList<>(); //thread-safe collection 
    for (Target t : targets) { 
     safeTargets.add(t); 
    } 
    safeTargets = Collections.synchronizedList(targets); 

    exec = Executors.newCachedThreadPool(); 

    for (int i = 0; i < 4; i++) { //number of threads 
     exec.execute(new Runnable() { 
      @Override 
      public void run() { 
       while (true) { 
        for (Target t : safeTargets) { 
         String ping = null; 
         if (t.isActive() && !t.isIsBeingPinged()) { //checks if target is already being pinged by another thread and if it flagged as active and wishes to be pinged. 
          t.setIsBeingPinged(true); 
          t.setPinged(t.getPinged() + 1); //just to see how many times it has been pinged 
          t.setStatus("PINGING"); 
          try { 
           Callable c = new Pinger(t); 
           ping = c.call().toString(); 
           switch (ping) { 
            case "TIME_OUT": 
             t.setStatus("TIME OUT"); 
             t.setLastrtt("TIME_OUT"); 
             t.setTimeouts(t.timeoutsProperty().get() + 1); 
             logUtil.log(LogUtil.INFO, t.nameProperty().get() + " - timed out!"); 
             t.setIsBeingPinged(false); 
             break; 
            case "UNKNOWN_HOST": 
             t.setStatus("ERROR"); 
             t.setLastrtt("UNKNOWN HOST"); 
             logUtil.log(LogUtil.WARNING, t.nameProperty().get() + " - unknown host!"); 
             t.setIsBeingPinged(false); 
             break; 
            case "UNREACHABLE": 
             t.setStatus("ERROR"); 
             t.setLastrtt("UNREACHABLE HOST"); 
             logUtil.log(LogUtil.WARNING, t.nameProperty().get() + " - is unreachable!"); 
             t.setIsBeingPinged(false); 
             break; 
            default: 
             t.setLastrtt(ping); 
             t.setStatus("ACTIVE"); 
             t.setIsBeingPinged(false); 
             break; 
           } 
           System.out.println("C=" + t.getPinged() + " - " + t.nameProperty().get()); 
          } catch (Exception e) { 
           logUtil.log(LogUtil.CRITICAL, e.getMessage() + ", " + e.getCause()); 
           e.printStackTrace(); 
          } 
         } 
        } 
       } 
      } 
     }); 
    } 
} 

나는 결국 차트에 즉시 추가 제거했다.

• 대상 목록 개체는 스레드 안전 동기화 목록 (kleopatra에서 제안한대로)에 추가됩니다.
• 부울 변수가 대상 모델에 추가되어 현재 스레드 중 하나에 의해 핑되고 있는지 확인합니다. (t.isIsBeingPinged())
• 동일한 풀에서 새로운 Runnable을 사용하여 데이터를 차트에 추가합니다.이 테이블은 낙하에서 더 높은 ping을 가진 대상을 피하기 위해 대상 목록을 반복하고 매 초마다 마지막 RTT를 차트에 추가합니다 뒤에 차트에.

매우 빠른 답변을 보내 주셔서 감사합니다.