drools-benchmarks-parent/drools-benchmarks/src/main/java/org/drools/benchmarks/concurrent/ConcurrentUpdateRightTupleBenchmark.java [108:129]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public int test() {
        ExecutorService executor = Executors.newFixedThreadPool(SESSIONS_NR);

        for (int n = 0; n < SESSIONS_NR; n++) {
            final int index = n;
            executor.execute(new Runnable() {

                public void run() {
                    int fired = kieSessions.get(index).fireAllRules();
//                    System.out.println(fired);
                }
            });
        }

        executor.shutdown();
        try {
            executor.awaitTermination(300, TimeUnit.SECONDS);
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
        return kieSessions.size();
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



drools-benchmarks-parent/drools-benchmarks/src/main/java/org/drools/benchmarks/concurrent/ConcurrentUpdateLeftTupleBenchmark.java [108:129]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public int test() {
        ExecutorService executor = Executors.newFixedThreadPool(SESSIONS_NR);

        for (int n = 0; n < SESSIONS_NR; n++) {
            final int index = n;
            executor.execute(new Runnable() {

                public void run() {
                    int fired = kieSessions.get(index).fireAllRules();
//                    System.out.println(fired);
                }
            });
        }

        executor.shutdown();
        try {
            executor.awaitTermination(300, TimeUnit.SECONDS);
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
        return kieSessions.size();
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -