}

    /**
     * Gets the next sequence number for this registration.
     *
     * @return the next sequence number
     */
    public long getNextSequenceNumber() {
        return sequenceNumber.incrementAndGet();
    }

    /**
     * Updates the heartbeat timestamp to current time and resets failure count.
     */
    public void updateHeartbeat() {
        this.lastHeartbeat = System.currentTimeMillis();

                        buffer[0] = (byte) i;

                        // Release buffer
                        BufferCache.releaseBuffer(buffer);
                        successCount.incrementAndGet();
                    }
                } catch (Exception e) {
                    synchronized (exceptions) {
                        exceptions.add(e);
                    }
                } finally {

                        String nonceStr = Arrays.toString(nonce);
                        if (allNonces.putIfAbsent(nonceStr, true) != null) {
                            collisions.incrementAndGet();
                        }
                    }
                } finally {
                    latch.countDown();
                }
            });
        }

        // Then

        ThumbnailManager mockThumbnailManager = new ThumbnailManager() {
            @Override
            public int generate(ExecutorService executorService, boolean cleanup) {
                counter.incrementAndGet();
                // Return 0 to exit the loop
                return 0;
            }
        };
        ComponentUtil.register(mockThumbnailManager, "thumbnailManager");
    }

    }

    /**
     * Increments the access count and returns the new value.
     * @return The incremented access count.
     */
    public long incrementAndGetAccessCount() {
        return accessCount.incrementAndGet();
    }

    /**
     * Decrements the access count and returns the new value.
     * @return The decremented access count.
     */
    public long decrementAndGetAccessCount() {

                                    matchCount.incrementAndGet();
                                }
                            } else {
                                responseData.setUrl("https://other.com/page" + j);
                                if (!rule.match(responseData)) {
                                    noMatchCount.incrementAndGet();
                                }
                            }

            k -> new ChannelStatistics());
            
        stats.operations.incrementAndGet();
        stats.latencyTotal.addAndGet(latency);
        
        if (success) {
            stats.bytesReceived.addAndGet(bytes);
        } else {
            stats.errors.incrementAndGet();
        }
    }
    
    public double getAggregatedThroughput() {

 *
 * {@snippet :
 * final String name = ...;
 * inFlight.add(name);
 * ListenableFuture<Result> future = service.query(name);
 * future.addListener(new Runnable() {
 *   public void run() {
 *     processedCount.incrementAndGet();
 *     inFlight.remove(name);
 *     lastProcessed.set(name);
 *     logger.info("Done with {0}", name);
 *   }
 * }, executor);
 * }
 *
 * <h3>How to get an instance</h3>
 *

      val threadName = "SocksProxy ${serverSocket!!.localPort}"
      Thread.currentThread().name = threadName
      try {
        while (true) {
          val socket = serverSocket!!.accept()
          connectionCount.incrementAndGet()
          service(socket)
        }
      } catch (e: SocketException) {
        logger.info("$threadName done accepting connections: ${e.message}")
      } catch (e: IOException) {

            if (!filter.test(problem)) {
                // drop without counting towards preserved problems
                return false;
            }
            int currentCount = totalCount.incrementAndGet();
            getCounter(problem.getSeverity()).increment();
            if (currentCount <= maxCountLimit || dropProblemWithLowerSeverity(problem.getSeverity())) {