package redis;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.Pipeline;
public class PipelineDemo {
private static Jedis jedis = new Jedis("192.168.10.250", 6379);
public static void pipeline(){
jedis.select(0);
Pipeline pipeline = jedis.pipelined();
long start = System.currentTimeMillis();
for(int i=0;i<10000;i++){
pipeline.set("p"+i, "p"+i);
}
pipeline.sync();
long end = System.currentTimeMillis();
System.out.println(end-start);
jedis.close();
}
public static void normal(){
jedis.select(0);
long start = System.currentTimeMillis();
for(int i=0;i<10000;i++){
jedis.set("p"+i, "p"+i);
}
long end = System.currentTimeMillis();
System.out.println(end-start);
}
public static void main(String[] args) {
pipeline();
// normal();
}
}
