@Test public void testInitialState() throws Exception { BucketedTimeDistribution distribution = new BucketedTimeDistribution(); distribution.add(1); assertPreviousDistributionEmpty(distribution); }
public void add(final long value) { applyToCurrentBucket((Function<Distribution, Void>) input -> { synchronized (input) { input.digest.add(value); input.total += value; } return null; }); }
BucketedTimeDistribution extends Bucketed<BucketedTimeDistribution.Distribution> { public void add(final long value) { applyToCurrentBucket((Function<Distribution, Void>) input -> { synchronized (input) { input.digest.add(value); input.total += value; } return null; }); } }
BucketedTimeDistribution extends Bucketed<BucketedTimeDistribution.Distribution> { public void add(final long value) { applyToCurrentBucket((Function<Distribution, Void>) input -> { synchronized (input) { input.digest.add(value); input.total += value; } return null; }); }  }
BucketedTimeDistribution extends Bucketed<BucketedTimeDistribution.Distribution> { public void add(final long value) { applyToCurrentBucket((Function<Distribution, Void>) input -> { synchronized (input) { input.digest.add(value); input.total += value; } return null; }); }  void add(final long value); }
BucketedTimeDistribution extends Bucketed<BucketedTimeDistribution.Distribution> { public void add(final long value) { applyToCurrentBucket((Function<Distribution, Void>) input -> { synchronized (input) { input.digest.add(value); input.total += value; } return null; }); }  void add(final long value);  }