Package java.util.concurrent.atomic

Examples of java.util.concurrent.atomic.AtomicInteger.incrementAndGet()

63
64
65
66
67
68
69
70
71
72
73
      public synchronized void createDatastore(Datastore datastore) {
        if (_datastore != null) {
          assertEquals(_datastore, datastore);
        }
        _datastore = datastore;
        datastoreCount.incrementAndGet();
      }
    };

    final InputColumn<?>[] columns = scenarioHelper.getColumns().toArray(new InputColumn[0]);
View Full Code Here
940
941
942
943
944
945
946
947
948
949
950
      chmQueryCount.put(sConnection, ai);

      al = new AtomicLong(0);
      chmQueryTime.put(sConnection, al);
    } else {
      ai.incrementAndGet();

      al = chmQueryTime.get(sConnection);
    }

    if (al == null) {
View Full Code Here
1252
1253
1254
1255
1256
1257
1258
1259
1260
1261
1262
                }
                PrintWriter writer = event.getResource().getResponse().getWriter();
                writer.write(event.getMessage().toString());
                writer.flush();
                try {
                     broadcastCount.incrementAndGet();
                } finally {
                    if (broadcastCount.get() == 4) {
                        event.getResource().resume();
                    }
                }
View Full Code Here
75
76
77
78
79
80
81
82
83
84
85
        AtomicInteger i = count.get();
        if (i == null) {
            i = new AtomicInteger(0);
            count.set(i);
        }
        i.incrementAndGet();
    }

    private void decrement() {
        AtomicInteger i = count.get();
        if (i == null) {
View Full Code Here
596
597
598
599
600
601
602
603
604
605
606
                    bufferedWrites.putIfAbsent(indexName, times);
                }
            }
        }

        int t = times.incrementAndGet();

        if (t > writeTreshold)
        {
            commit(indexName, false);
            times.set(0);
View Full Code Here
442
443
444
445
446
447
448
449
450
451
452
            // Make sure that regions are assigned to server
            if (value != null && value.length > 0) {
              hostAndPort = Bytes.toString(value);
            }
            if (!(info.isOffline() || info.isSplit()) && hostAndPort != null) {
              actualRegCount.incrementAndGet();
            }
            return true;
          }
        };
        MetaScanner.metaScan(conf, visitor, desc.getName());
View Full Code Here
353
354
355
356
357
358
359
360
361
362
363
                    {
                        @Override
                        public boolean allowRetry(int retryCount, long elapsedTimeMs, RetrySleeper sleeper)
                        {
                            semaphore.release();
                            if ( retries.incrementAndGet() == MAX_RETRIES )
                            {
                                try
                                {
                                    server = new TestingServer(serverPort);
                                }
View Full Code Here
184
185
186
187
188
189
190
191
192
193
194
    AtomicInteger counter = logFileIDReferenceCounts.get(fileID);
    if(counter == null) {
      counter = new AtomicInteger(0);
      logFileIDReferenceCounts.put(fileID, counter);
    }
    counter.incrementAndGet();
  }
  @Override
  protected void decrementFileID(int fileID) {
    AtomicInteger counter = logFileIDReferenceCounts.get(fileID);
    Preconditions.checkState(counter != null, "null counter ");
View Full Code Here
421
422
423
424
425
426
427
428
429
430
431
          // Make sure that regions are assigned to server
          if (value != null && value.length > 0) {
            hostAndPort = Bytes.toString(value);
          }
          if (!(info.isOffline() || info.isSplit()) && hostAndPort != null) {
            actualRegCount.incrementAndGet();
          }
          return true;
        }
      };
      MetaScanner.metaScan(conf, visitor, desc.getName());
View Full Code Here
259
260
261
262
263
264
265
266
267
268
269
                        {
                            i = new AtomicInteger(1);
                            invalidMutations.put(ex.cfId, i);
                        }
                        else
                            i.incrementAndGet();
                        continue;
                    }
                   
                    if (logger.isDebugEnabled())
                        logger.debug(String.format("replaying mutation for %s.%s: %s",
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.