gistfile1.java

  public static void query()
        throws Exception {
        db.getLastError(2,2,false); // make sure socket is clear

        List<Thread> all = new ArrayList<Thread>();
        for ( int i=0; i<NUM_THREADS; i++ )
            all.add( new Runner() );
        
        long start = System.currentTimeMillis();
        int before = UPTO.get();

        for ( Thread t : all )
            t.start();
        for ( Thread t : all )
            t.join();

        long end = System.currentTimeMillis();        
        int after = UPTO.get();
        
        System.out.println( "queries/sec: " + ( 1000.0 * ( after-before) / ( end - start ) ));
    }