redis incr incrby decr decrby命令

心心失意

/**　　* 并发100个线程,50个线程做decr命令,另外50个线程做incr命令
　　*
　　*
@author tianshu on 16/10/31 上午10:52.*/
　　
public>　　

　　/** decr线程数量 */
　　private static final int DECR_THREAD_COUNT = 50;
　　/** incr线程数量 */
　　private static final int INCR_THREAD_COUNT = 50;
　　

　　private static CountDownLatch begin = new CountDownLatch(DECR_THREAD_COUNT + INCR_THREAD_COUNT);
　　

　　private static CountDownLatch finish = new CountDownLatch(DECR_THREAD_COUNT + INCR_THREAD_COUNT);
　　

　　static final String KEY = "string:decr:incr";
　　

　　

　　public static void main(String[] args) throws InterruptedException {
　　

　　for(int i = 0; i < DECR_THREAD_COUNT; ++i) {
　　new DecrThread().start();
　　begin.countDown();
　　}
　　

　　for(int i = 0; i < INCR_THREAD_COUNT; ++i) {
　　new IncrThread().start();
　　begin.countDown();
　　}
　　

　　finish.await();
　　

　　JedisConnect jedisConnect = JedisConnect.getJedisConnect();
　　Jedis jedis = jedisConnect.getJedis();
　　

　　String value = jedis.get(KEY);
　　System.out.println(value);
　　

　　jedisConnect.releaseJedis(jedis);
　　}
　　

　　/**
　　* decr命令线程
　　*/

　　static>　　

　　@Override
　　public void run() {
　　

　　try {
　　begin.await();
　　} catch (InterruptedException e) {
　　e.printStackTrace();
　　}
　　

　　JedisConnect jedisConnect = JedisConnect.getJedisConnect();
　　Jedis jedis = jedisConnect.getJedis();
　　

　　jedis.decr(KEY);
　　jedisConnect.releaseJedis(jedis);
　　

　　finish.countDown();
　　}
　　}
　　

　　/**
　　* incr命令线程
　　*/

　　static>　　

　　@Override
　　public void run() {
　　

　　try {
　　begin.await();
　　} catch (InterruptedException e) {
　　e.printStackTrace();
　　}
　　

　　JedisConnect jedisConnect = JedisConnect.getJedisConnect();
　　Jedis jedis = jedisConnect.getJedis();
　　

　　jedis.incr(KEY);
　　jedisConnect.releaseJedis(jedis);
　　

　　finish.countDown();
　　}
　　

　　}
　　

　　
}