Как выполнить одновременно две операции?

Question

Я строю тестовую упряжь в java и пытаюсь сравнить производительность и латентность двух парсеров. Разбирает данные, полученные от одного живого, одного канала. У меня нет контроля над фидом, и у меня нет «имитированного фида» для издевательских данных, поэтому для сравнения яблок с яблоками я бы хотел, чтобы мои анализы проводились как можно раньше. Я новичок в java и threading, поэтому не уверен, что это лучший подход. Моя идея состояла в том, чтобы открутить 2 резьбы:

SomeFeed feed = new SomeFeed(); 

Thread thread1 = new Thread() { 
    public void run() { 
    parser1.parseFeed(feed); 
    } 
}; 
Thread thread2 = new Thread() { 
    public void run() { 
    parse2.parseFeed(feed); 
    } 
}; 
thread1.start(); 
thread2.start(); 

Будет ли поток работать таким образом примерно синхронно? Или есть лучший подход?

Благодаря

Answer 1

Имея два потока работать точно параллельно не то, что вы можете реально контролировать. Но если вы заботитесь о начиная их в то же время (почти) вы можете использовать CyclicBarrier (взято из here):

// We want to start just 2 threads at the same time, but let's control that 
// timing from the main thread. That's why we have 3 "parties" instead of 2. 
final CyclicBarrier gate = new CyclicBarrier(3); 

Thread t1 = new Thread(){ 
    public void run(){ 
     gate.await(); 
     //do stuff  
    }}; 
Thread t2 = new Thread(){ 
    public void run(){ 
     gate.await(); 
     //do stuff  
    }}; 

t1.start(); 
t2.start(); 

// At this point, t1 and t2 are blocking on the gate. 
// Since we gave "3" as the argument, gate is not opened yet. 
// Now if we block on the gate from the main thread, it will open 
// and all threads will start to do stuff! 

gate.await(); 
System.out.println("all threads started"); 

Это поможет вам ближе всего к запуская их одновременно.

Answer 2

Это один из способов делать вещи. Другим способом является внедрение интерфейса Runnable.

public class SomeFeed implements Runnable { 

    public void run() { 
     System.out.println("Hello from a thread!"); 
    } 

    public static void main(String args[]) { 
     (new Thread(new SomeFeed())).start(); 
    } 

} 

Новый подход заключается в использовании ThreadPool.

Это способ, которым Вы могли бы создать пул и выполнить код

ExecutorService pool = Executors.newFixedThreadPool(2); 

for(int i = 0; i < 2; i++){ 
    pool.submit(new SomeFeed()); 


} 

Убедитесь SomeFeed Реализует Callable интерфейс.

Более подробную информацию можно найти here

Answer 3

Независимо от вас одной проблемы подачи, запуск парсеров одновременно о худший способ их сравнения.

Сохраните подачу в сторону, чтобы стать вашим справочным набором данных для обоих тестов.

Вам необходимо измерить время, которое они взяли, по крайней мере, в то время как процессор был надежно доступен без помех.

И вы также должны сделать более 1500 прогонов, чтобы иметь справедливую меру времени avg, которое принимает подпрограмма (1500 вызовов метода - это порог для компиляции JIT Hotspot, которая ускоряет код). Кроме того, постарайтесь, чтобы код работал не менее 30 секунд, чтобы также можно было усреднить потенциальные помехи для вариантов ОС и дисков.

И если вы заметили паузу GC (всегда включаете журнал gc во время тестов), тогда вам нужно запустить тест либо в большем объеме памяти, чтобы избежать полного gc (например, использовать -Xmx2G), либо выполнить тест так часто, что число полных ГХ довольно равномерно в обоих парсерах.

Во всяком случае, злоупотребления памяти и, следовательно, время GC также являются фактором производительности, чтобы судить о худшем парсере.