LinkedBlockingQueue에서 put()의 성능

Question

키 기능은 다른 시스템의 데이터를 최대한 빨리 (차단하지 않고) 받아들이는 것입니다. 내 응용 프로그램은 나중에 데이터를 처리합니다.

그렇다면 내가 메시지를 LinkedBlockingQueue/LinkedTransferQueue에 큐에 대기시킨 다음 주기적으로 큐를 비우고 백그라운드 스레드에서 데이터를 처리하는 것이 었습니다.

private final LinkedTransferQueue<Data> queue = new LinkedTransferQueue<Data>(); 

    public void store(int index, long time, String[] data) throws InterruptedException{ 
     Data data = new Data(index, time, data); 
     queue.put(data); 
    } 

    private class BackgroundProcessor implements Runnable{ 

    private List<Data> entryList = new LinkedList<Data>(); 

    @Override 
    public void run(){ 

     try { 
      while (keepProcessing){ 

       int count = queue.drainTo(entryList); 

       for (Data data : entryList){ 
       //process data 
       } 
      } 
     } catch(Exception e){ 
       logger.error("Exception while processing data.", e); 
     } 
    } 

} 

내가 다음이 방법의 성능을 테스트하고 싶었 :의 라인을 따라

그래서 뭔가

public void testStore(String[] dataArray) throws InterruptedException{ 

     int size = 100 * 1000; 

     long iTime = System.nanoTime(); 
     for (int i=0; i < size; i++){ 
      store(i, System.nanoTime, dataArray); 
     } 
     long fTime = System.nanoTime(); 

     System.err.println("Average Time (nanos): " + (fTime - iTime)/size; 

     float avgTimeInMicros = ((float) (fTime - iTime)/(size * 1000)); 
     System.err.println("Average Time (micros): " + avgTimeInMicros); 
    } 

내가 볼을 나의 testStore()에서, 크기 = 100의 경우, 0000, 나는 불변의 객체 인 Data 객체를 만들고 0.8 마이크로 초 안에 대기시킬 수 있습니다. 그러나 크기를 50으로 줄이면 20 마이크로가 필요합니다.

잠시 후 jvm을 사용하면 코드가 최적화됩니다. 그러나, 내 응용 프로그램에서 버스트 크기에 상관없이 1-2 개의 마이크로 메시지를 대기열에 넣기 위해 jvm (또는 내 코드)을 조정할 수있는 방법이 있습니까?

P.S jmk 1.6에서 -mx == -ms 512m으로이 테스트를 시도했습니다.

Answer 1

10,000을 처리 한 다음 JVM이 예열 된 후 버스트가 50인지 테스트합니다. 거래 시스템의 경우 거래를 시작하기 전에 JVM이 예열되었는지 확인해야합니다.

거래 시스템을 일관되게 빨리 만들고 싶다면 어떤 물건을 버리지 않고 어떻게 할 수 있는지 생각할 수 있습니다.

흥미있는 Disruptor 라이브러리를 찾을 수 있습니다. 초당 5M 메시지를 처리하도록 설계되었습니다. http://code.google.com/p/disruptor/