스칼라를 사용하는 CQEngine 결과 집합 foreach가 매우 느립니다.

Question

스칼라의 foreach를 사용하여 CQEngine의 ResultSet을 처리하려고하는데 결과가 매우 느립니다. 다음

는

어떻게 든 .foreach 방법은 매우 느립니다 내가

import collection.JavaConversions._ 
val query = existIn(myOtherCollection, REFERENCE, REFERENCE) 
val resultSet = myIndexCollection.retrieve(query) 
resultSet.foreach(r =>{ 
    //do something here 
}) 

을 할 노력하고있어의 조각입니다. 나는 SimonMonitor를 넣고 디버그 하려다가 while(resultSet.hasNext)을 사용하여 .foreach를 변경했다. 놀랍게도 hasNext 메서드를 호출 할 때마다 약 1-2 초가 걸린다. 매우 느립니다.

Java를 사용하여 동일한 버전을 만들려고했는데 Java 버전이 매우 빠릅니다.

도와주세요

Answer 1

아래의 테스트 코드로 문제를 재현 할 수 없습니다. 당신은 당신의 시스템에서 그것을 시험해보고 그것을 어떻게 실행하는지 알려 줄 수 있습니까?

(BOTH 스칼라와 자바 반복자는 엄청나게 빠르게 실행할 수 있도록 주석을 해제 라인 (38), garages.addIndex(HashIndex.onAttribute(Garage.BRANDS_SERVICED)), ...) 처음

출력 (밀리 초 시간) : 아래

Done adding data 
Done adding index 
============== Scala ============== 
Car{carId=4, name='BMW M3', description='2013 model', features=[radio, convertible]} 
Time : 3 seconds 
Car{carId=1, name='Ford Focus', description='great condition, low mileage', features=[spare tyre, sunroof]} 
Time : 1 seconds 
Car{carId=2, name='Ford Taurus', description='dirty and unreliable, flat tyre', features=[spare tyre, radio]} 
Time : 2 seconds 
============== Java ============== 
Car{carId=4, name='BMW M3', description='2013 model', features=[radio, convertible]} 
Time : 3 seconds 
Car{carId=1, name='Ford Focus', description='great condition, low mileage', features=[spare tyre, sunroof]} 
Time : 1 seconds 
Car{carId=2, name='Ford Taurus', description='dirty and unreliable, flat tyre', features=[spare tyre, radio]} 
Time : 2 seconds 

코드 :

import collection.JavaConversions._ 
import com.googlecode.cqengine.query.QueryFactory._ 
import com.googlecode.cqengine.CQEngine; 
import com.googlecode.cqengine.index.hash._; 
import com.googlecode.cqengine.IndexedCollection; 
import com.googlecode.cqengine.query.Query; 
import java.util.Arrays.asList; 

object CQTest { 

    def main(args: Array[String]) { 

    val cars: IndexedCollection[Car] = CQEngine.newInstance(); 
    cars.add(new Car(1, "Ford Focus", "great condition, low mileage", asList("spare tyre", "sunroof"))); 
    cars.add(new Car(2, "Ford Taurus", "dirty and unreliable, flat tyre", asList("spare tyre", "radio"))); 
    cars.add(new Car(3, "Honda Civic", "has a flat tyre and high mileage", asList("radio"))); 
    cars.add(new Car(4, "BMW M3", "2013 model", asList("radio", "convertible"))); 

    // add cruft to try and slow down CQE 
    for (i <- 1 to 10000) { 
     cars.add(new Car(i, "BMW2014_" + i, "2014 model", asList("radio", "convertible"))) 
    } 

    // Create an indexed collection of garages... 
    val garages: IndexedCollection[Garage] = CQEngine.newInstance(); 
    garages.add(new Garage(1, "Joe's garage", "London", asList("Ford Focus", "Honda Civic"))); 
    garages.add(new Garage(2, "Jane's garage", "Dublin", asList("BMW M3"))); 
    garages.add(new Garage(3, "John's garage", "Dublin", asList("Ford Focus", "Ford Taurus"))); 
    garages.add(new Garage(4, "Jill's garage", "Dublin", asList("Ford Focus"))); 

    // add cruft to try and slow down CQE 
    for (i <- 1 to 10000) { 
     garages.add(new Garage(i, "Jill's garage", "Dublin", asList("DONT_MATCH_CARS_BMW2014_" + i))) 
    } 

    println("Done adding data") 
    // cars.addIndex(HashIndex.onAttribute(Car.NAME)); 
    // garages.addIndex(HashIndex.onAttribute(Garage.BRANDS_SERVICED)); 
    println("Done adding index") 
    val query = existsIn(garages, Car.NAME, Garage.BRANDS_SERVICED, equal(Garage.LOCATION, "Dublin")) 
    val resultSet = cars.retrieve(query) 

    var previous = System.currentTimeMillis() 
    println("============== Scala ============== ") 
    // Scala version 
    resultSet.foreach(r => { 
     println(r); 
     val t = (System.currentTimeMillis() - previous) 
     System.out.println("Time : " + t/1000 + " seconds") 
     previous = System.currentTimeMillis() 
    }) 

    println("============== Java ============== ") 
    previous = System.currentTimeMillis() 
    // Java version 
    val i: java.util.Iterator[Car] = resultSet.iterator() 
    while (i.hasNext) { 
     val r = i.next() 
     println(r); 
     val t = (System.currentTimeMillis() - previous) 
     System.out.println("Time : " + t/1000 + " seconds") 
     previous = System.currentTimeMillis() 
    } 
    } 
}