Package org.jredis.ri.alphazero

Examples of org.jredis.ri.alphazero.JRedisPipeline.incr()

32
33
34
35
36
37
38
39
40
41
42
   
    for(;;){
      Future<Long> frCounter = null;
      long start = System.nanoTime();
      for(int i=0;i<iters; i++){
        frCounter = jredis.incr(key);
      }
      long queued = System.nanoTime() - start;
      try {
        long counter = frCounter.get();
        long delta_ns = System.nanoTime() - start;
View Full Code Here
88
89
90
91
92
93
94
95
96
97
98
          /* sync call */
          long llen = pipeline.sync().llen("my-list");
         
          String cntrKey = "my-cntr";
          for(int i=0; i<100000; i++) {
            pipeline.incr(cntrKey);
          }
          /* sync call */
          long cntr = toLong (pipeline.sync().get(cntrKey));
         
          for(int i=0; i<100000; i++){
View Full Code Here
71
72
73
74
75
76
77
78
79
80
81
          String cntrKey = "my-cntr";
         
          Random rand = new Random();
          byte[] data = new byte[8];
          for(int i=0; i<100000; i++)
            pipeline.incr(cntrKey);
         
          long cntr = toLong (pipeline.sync().get(cntrKey));
         
          for(int i=0; i<100000; i++){
            rand.nextBytes(data);
View Full Code Here
321
322
323
324
325
326
327
328
329
330
331
        do {
          int cnt = 0;
          Util.Timer timer = Timer.startNewTimer();
          Future<Long> futureLong = null;
          while(cnt < reqCnt){
            futureLong = pipeline.incr(key);
            cnt++;
          }
          long reqDoneTime = timer.mark();
        long counter = futureLong.get();
          long respDoneTime = timer.mark();
View Full Code Here
97
98
99
100
101
102
103
104
105
106
107
         
          long llen = pipeline.sync().llen("my-list");
         
          String cntrKey = "my-cntr";
          for(int i=0; i<100000; i++) {
            pipeline.incr(cntrKey);
          }
          /* sync call */
          long cntr = toLong (pipeline.sync().get(cntrKey));
         
          for(int i=0; i<100000; i++){
View Full Code Here
74
75
76
77
78
79
80
81
82
83
84
          String cntrKey = "my-cntr";
         
          Random rand = new Random();
          byte[] data = new byte[8];
          for(int i=0; i<100000; i++)
            pipeline.incr(cntrKey);
         
          long cntr = toLong (pipeline.sync().get(cntrKey));
         
          for(int i=0; i<100000; i++){
            rand.nextBytes(data);
View Full Code Here
331
332
333
334
335
336
337
338
339
340
341
        do {
          int cnt = 0;
          Util.Timer timer = Timer.startNewTimer();
          Future<Long> futureLong = null;
          while(cnt < reqCnt){
            futureLong = pipeline.incr(key);
            cnt++;
          }
          long reqDoneTime = timer.mark();
          assert futureLong != null;
        @SuppressWarnings("null")
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.