memcacheq一个国内开发的message queue之性能研究

        cc.set("q", DATA100);
        count.incrementAndGet();
    }
    
    private static void printStat(long time1) {
        while (true) {
            long time2 = System.currentTimeMillis();
            if (time2 == time1)
                continue;
            int cnt = count.get();
            
            System.out.println("---------------------------");
            System.out.println("Total: " + cnt);

            System.out.print("Time elapsed: ");
            System.out.println((time2 - time1) / 1000);
            
            System.out.print("AVG: ");
            System.out.println(cnt * 1000l / (time2 - time1));
            try {
                Thread.sleep(3000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}