http://git-wip-us.apache.org/repos/asf/aurora/blob/06ddaadb/commons/src/main/java/com/twitter/common/util/QueueDrainer.java ---------------------------------------------------------------------- diff --git a/commons/src/main/java/com/twitter/common/util/QueueDrainer.java b/commons/src/main/java/com/twitter/common/util/QueueDrainer.java deleted file mode 100644 index 2903076..0000000 --- a/commons/src/main/java/com/twitter/common/util/QueueDrainer.java +++ /dev/null @@ -1,53 +0,0 @@ -/** - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package com.twitter.common.util; - -import java.util.concurrent.BlockingQueue; -import java.util.concurrent.Executor; - -import com.google.common.base.Preconditions; - -/** - * Joins a task queue with an executor service, to add control over when - * tasks are actually made available for execution. - * - * @author Srinivasan Rajagopal - */ -public class QueueDrainer<T extends Runnable> implements Runnable { - - private final Executor taskExecutor; - private final BlockingQueue<T> blockingQueue; - - /** - * Creates a QueueDrainer that associates the queue with an executorService. - * - * @param taskExecutor Executor to execute a task if present. - * @param blockingQueue Queue to poll if there is a runnable to execute. - */ - public QueueDrainer(Executor taskExecutor, BlockingQueue<T> blockingQueue) { - this.taskExecutor = Preconditions.checkNotNull(taskExecutor); - this.blockingQueue = Preconditions.checkNotNull(blockingQueue); - } - - /** - * Picks tasks from the Queue to execute if present else no-op. - */ - @Override - public void run() { - Runnable command = blockingQueue.poll(); - if (command != null) { - taskExecutor.execute(command); - } - } -}
http://git-wip-us.apache.org/repos/asf/aurora/blob/06ddaadb/commons/src/main/java/com/twitter/common/util/Random.java ---------------------------------------------------------------------- diff --git a/commons/src/main/java/com/twitter/common/util/Random.java b/commons/src/main/java/com/twitter/common/util/Random.java deleted file mode 100644 index dd95428..0000000 --- a/commons/src/main/java/com/twitter/common/util/Random.java +++ /dev/null @@ -1,78 +0,0 @@ -/** - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package com.twitter.common.util; - -import com.google.common.base.Preconditions; - -/** - * An interface to define the common functionality that is required for generating random values. - * - * @author William Farner - */ -public interface Random { - - /** - * @see java.util.Random#nextDouble() - */ - public double nextDouble(); - - /** - * @see java.util.Random#nextInt(int) - */ - public int nextInt(int n); - - /** - * A Random that wraps a java.util.Random. - */ - static class SystemRandom implements Random { - private final java.util.Random rand; - - public SystemRandom(java.util.Random rand) { - this.rand = Preconditions.checkNotNull(rand); - } - - @Override - public double nextDouble() { - return rand.nextDouble(); - } - - @Override - public int nextInt(int n) { - return rand.nextInt(n); - } - } - - // Utility class. - public static class Util { - private Util() {} - - /** - * Creates a new Random based off the default system Random. - * @return A new default Random. - */ - public static Random newDefaultRandom() { - return new SystemRandom(new java.util.Random()); - } - - /** - * Adapts a java.util.Random into a Random. - * - * @param rand The java.util.Random to adapt. - * @return A new Random. - */ - public static Random fromSystemRandom(java.util.Random rand) { - return new SystemRandom(rand); - } - } -} http://git-wip-us.apache.org/repos/asf/aurora/blob/06ddaadb/commons/src/main/java/com/twitter/common/util/RangeNormalizer.java ---------------------------------------------------------------------- diff --git a/commons/src/main/java/com/twitter/common/util/RangeNormalizer.java b/commons/src/main/java/com/twitter/common/util/RangeNormalizer.java deleted file mode 100644 index 96e4844..0000000 --- a/commons/src/main/java/com/twitter/common/util/RangeNormalizer.java +++ /dev/null @@ -1,88 +0,0 @@ -/** - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -//************************************************************************ -// -// Summize -// -// This work protected by US Copyright Law and contains proprietary and -// confidential trade secrets. -// -// (c) Copyright 2006 Summize, ALL RIGHTS RESERVED. -// -//************************************************************************ -package com.twitter.common.util; - -/** - * Generic range normalizer class. Values must be positive. - * - * @author Abdur Chowdhury - */ -public class RangeNormalizer { - public RangeNormalizer(double minA, double maxA, double minB, double maxB) { - _minA = minA; - _maxA = maxA; - _minB = minB; - _maxB = maxB; - _denominator = (_maxA - _minA); - _B = (_maxB - _minB); - _midB = minB + (_B / 2f); - } - - public double normalize(double value) { - // if no input range, return a mid range value - if (_denominator == 0) { - return _midB; - } - - return ((value - _minA) / _denominator) * _B + _minB; - } - - public static double normalize(double value, double minA, double maxA, double minB, double maxB) { - // if the source min and max are equal, don't return 0, return something - // in the target range (perhaps this "default" should be another argument) - if (minA == maxA) { - return minB; - } - - return ((value - minA) / (maxA - minA)) * (maxB - minB) + minB; - } - - public static float normalizeToStepDistribution(double rating) { - int integerRating = (int) Math.round(rating); - - if (integerRating == 2) { - integerRating = 1; - } else if (integerRating == 4) { - integerRating = 3; - } else if (integerRating == 6) { - integerRating = 5; - } else if (integerRating == 8) { - integerRating = 7; - } else if (integerRating == 9) { - integerRating = 10; - } - - return (float) integerRating; - } - - // ******************************************************************* - private double _denominator; - private double _B; - private double _minA = Double.MIN_VALUE; - private double _maxA = Double.MAX_VALUE; - private double _minB = Double.MIN_VALUE; - private double _maxB = Double.MAX_VALUE; - private double _midB = Double.MAX_VALUE; -} - http://git-wip-us.apache.org/repos/asf/aurora/blob/06ddaadb/commons/src/main/java/com/twitter/common/util/RateLimitedCommandExecutor.java ---------------------------------------------------------------------- diff --git a/commons/src/main/java/com/twitter/common/util/RateLimitedCommandExecutor.java b/commons/src/main/java/com/twitter/common/util/RateLimitedCommandExecutor.java deleted file mode 100644 index 4e117c4..0000000 --- a/commons/src/main/java/com/twitter/common/util/RateLimitedCommandExecutor.java +++ /dev/null @@ -1,90 +0,0 @@ -/** - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package com.twitter.common.util; - -import java.util.concurrent.BlockingQueue; -import java.util.concurrent.ScheduledExecutorService; -import java.util.concurrent.TimeUnit; -import java.util.logging.Level; -import java.util.logging.Logger; - -import com.google.common.base.Preconditions; - -import com.twitter.common.base.ExceptionalCommand; -import com.twitter.common.quantity.Amount; -import com.twitter.common.quantity.Time; - -import static com.google.common.base.Preconditions.checkArgument; -import static com.google.common.base.Preconditions.checkNotNull; - -/** - * CommandExecutor that invokes {@code queueDrainer} with a best-effort - * mechanism to execute with a fixed interval between requests of {@code - * intervalBetweenRequests}. - * - * @author Srinivasan Rajagopal - */ -public class RateLimitedCommandExecutor implements CommandExecutor { - - private static final Logger LOG = Logger.getLogger(RateLimitedCommandExecutor.class.getName()); - - private final BlockingQueue<RetryingRunnable<?>> blockingQueue; - - /** - * Create a CommandExecutor that executes enquequed tasks in the task - * executor with specified interval between executions. - * - * @param taskExecutor executor for periodic execution of enqueued tasks. - * @param intervalBetweenRequests interval between requests to rate limit - * request rate. - * @param queueDrainer A runnable that is responsible for draining the queue. - * @param blockingQueue Queue to keep outstanding work in. - */ - public RateLimitedCommandExecutor( - ScheduledExecutorService taskExecutor, - Amount<Long, Time> intervalBetweenRequests, - Runnable queueDrainer, - BlockingQueue<RetryingRunnable<?>> blockingQueue) { - - checkNotNull(taskExecutor); - checkNotNull(intervalBetweenRequests); - checkArgument(intervalBetweenRequests.as(Time.MILLISECONDS) > 0); - checkNotNull(queueDrainer); - this.blockingQueue = checkNotNull(blockingQueue); - taskExecutor.scheduleWithFixedDelay( - getSafeRunner(queueDrainer), - 0, - intervalBetweenRequests.as(Time.MILLISECONDS), - TimeUnit.MILLISECONDS); - } - - private static Runnable getSafeRunner(final Runnable runnable) { - return new Runnable() { - @Override public void run() { - try { - runnable.run(); - } catch (RuntimeException t) { - LOG.log(Level.INFO, " error processing task " + runnable); - } - } - }; - } - - @Override - public <E extends Exception> void execute(String name, ExceptionalCommand<E> task, - Class<E> exceptionClass, int numTries, Amount<Long, Time> retryDelay) { - blockingQueue.add(new RetryingRunnable<E>(name, task, exceptionClass, - numTries, retryDelay, this)); - } -} http://git-wip-us.apache.org/repos/asf/aurora/blob/06ddaadb/commons/src/main/java/com/twitter/common/util/RetryingRunnable.java ---------------------------------------------------------------------- diff --git a/commons/src/main/java/com/twitter/common/util/RetryingRunnable.java b/commons/src/main/java/com/twitter/common/util/RetryingRunnable.java deleted file mode 100644 index b3a3ba5..0000000 --- a/commons/src/main/java/com/twitter/common/util/RetryingRunnable.java +++ /dev/null @@ -1,131 +0,0 @@ -/** - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package com.twitter.common.util; - -import java.util.logging.Level; -import java.util.logging.Logger; - -import com.google.common.base.Throwables; - -import org.apache.commons.lang.builder.ToStringBuilder; - -import com.twitter.common.base.ExceptionalCommand; -import com.twitter.common.quantity.Amount; -import com.twitter.common.quantity.Time; - -import static com.google.common.base.Preconditions.checkArgument; -import static com.google.common.base.Preconditions.checkNotNull; - -/** - * A runnable task that is retried in a user-configurable fashion. - * - * @param <E> The type of exception that the ExceptionalCommand throws. - * - * @author Utkarsh Srivastava - */ -public class RetryingRunnable<E extends Exception> implements Runnable { - private final String name; - private final int tryNum; - private final int numTries; - private final Amount<Long, Time> retryDelay; - private final ExceptionalCommand<E> task; - private final CommandExecutor commandExecutor; - private final Class<E> exceptionClass; - - private static final Logger LOG = Logger.getLogger(RetryingRunnable.class.getName()); - - /** - * Create a Task with name {@code name} that executes at most {@code numTries} - * in case of failure with an interval of {@code retryDelay} between attempts. - * - * @param name Human readable name for this task. - * @param task the task to execute. - * @param exceptionClass class of the exception thrown by the task. - * @param numTries the total number of times to try. - * @param retryDelay the delay between successive tries. - * @param commandExecutor Executor to resubmit retries to. - * @param tryNum the seq number of this try. - */ - public RetryingRunnable( - String name, - ExceptionalCommand<E> task, - Class<E> exceptionClass, - int numTries, - Amount<Long, Time> retryDelay, - CommandExecutor commandExecutor, - int tryNum) { - - this.name = checkNotNull(name); - this.task = checkNotNull(task); - this.exceptionClass = checkNotNull(exceptionClass); - this.retryDelay = checkNotNull(retryDelay); - this.commandExecutor = checkNotNull(commandExecutor); - checkArgument(numTries > 0); - this.tryNum = tryNum; - this.numTries = numTries; - } - - /** - * Create a Task with name {@code name} that executes at most {@code numTries} - * in case of failure with an interval of {@code retryDelay} between attempts - * and sets tryNum to be the first (=1). - * - * @param name Human readable name for this task. - * @param task the task to execute. - * @param exceptionClass class of the exception thrown by the task. - * @param numTries the total number of times to try. - * @param retryDelay the delay between successive tries. - * @param commandExecutor Executor to resubmit retries to. - */ - public RetryingRunnable( - String name, - ExceptionalCommand<E> task, - Class<E> exceptionClass, - int numTries, - Amount<Long, Time> retryDelay, - CommandExecutor commandExecutor) { - - this(name, task, exceptionClass, numTries, retryDelay, commandExecutor, /*tryNum=*/ 1); - } - - @Override - public void run() { - try { - task.execute(); - } catch (Exception e) { - if (e.getClass().isAssignableFrom(exceptionClass)) { - if (tryNum < numTries) { - commandExecutor.execute(name, task, exceptionClass, numTries - 1, retryDelay); - } else { - LOG.log(Level.INFO, "Giving up on task: " + name + " " - + "after " + "trying " + numTries + " times" + ".", e); - } - } else { - LOG.log(Level.INFO, "Giving up on task: " + name + " after trying " - + numTries + " times. " + "due to unhandled exception ", e); - throw Throwables.propagate(e); - } - } - } - - @Override - public String toString() { - return new ToStringBuilder(this) - .append("name", name) - .append("tryNum", tryNum) - .append("numTries", numTries) - .append("retryDelay", retryDelay) - .toString(); - } -} http://git-wip-us.apache.org/repos/asf/aurora/blob/06ddaadb/commons/src/main/java/com/twitter/common/util/Sampler.java ---------------------------------------------------------------------- diff --git a/commons/src/main/java/com/twitter/common/util/Sampler.java b/commons/src/main/java/com/twitter/common/util/Sampler.java deleted file mode 100644 index 97400dd..0000000 --- a/commons/src/main/java/com/twitter/common/util/Sampler.java +++ /dev/null @@ -1,54 +0,0 @@ -/** - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package com.twitter.common.util; - -import com.google.common.base.Preconditions; - -/** - * A sampler that implements logic for fractional random selection. - * - * @author William Farner - */ -public class Sampler { - - private final Random rand; - private final double threshold; - - /** - * Creates a new sampler using the default system {@link Random}. - * - * @param selectPercent Percentage to randomly select, must be between 0 and 100 (inclusive). - */ - public Sampler(float selectPercent) { - this(selectPercent, Random.Util.newDefaultRandom()); - } - - /** - * Creates a new sampler using the provided {@link Random}. - * - * @param selectPercent Percentage to randoml select, must be between 0 and 100 (inclusive). - * @param rand The random utility to use for generating random numbers. - */ - public Sampler(float selectPercent, Random rand) { - Preconditions.checkArgument((selectPercent >= 0) && (selectPercent <= 100), - "Invalid selectPercent value: " + selectPercent); - - this.threshold = selectPercent / 100; - this.rand = Preconditions.checkNotNull(rand); - } - - public boolean select() { - return rand.nextDouble() < threshold; - } -} http://git-wip-us.apache.org/repos/asf/aurora/blob/06ddaadb/commons/src/main/java/com/twitter/common/util/StartWatch.java ---------------------------------------------------------------------- diff --git a/commons/src/main/java/com/twitter/common/util/StartWatch.java b/commons/src/main/java/com/twitter/common/util/StartWatch.java deleted file mode 100644 index 08afa78..0000000 --- a/commons/src/main/java/com/twitter/common/util/StartWatch.java +++ /dev/null @@ -1,48 +0,0 @@ -/** - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -//************************************************************************ -// -// Summize -// -// This work protected by US Copyright Law and contains proprietary and -// confidential trade secrets. -// -// (c) Copyright 2007 Summize, ALL RIGHTS RESERVED. -// -//************************************************************************ - -package com.twitter.common.util; - -import org.apache.commons.lang.time.StopWatch; - -public class StartWatch extends StopWatch { - public StartWatch() { - super(); - } - - public void start() { - _started = true; - super.start(); - } - - public void resume() { - if (!_started) { - start(); - } else { - super.resume(); - } - } - - private boolean _started = false; -} http://git-wip-us.apache.org/repos/asf/aurora/blob/06ddaadb/commons/src/main/java/com/twitter/common/util/Stat.java ---------------------------------------------------------------------- diff --git a/commons/src/main/java/com/twitter/common/util/Stat.java b/commons/src/main/java/com/twitter/common/util/Stat.java deleted file mode 100644 index 4f10ea0..0000000 --- a/commons/src/main/java/com/twitter/common/util/Stat.java +++ /dev/null @@ -1,351 +0,0 @@ -/** - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package com.twitter.common.util; - -//*************************************************************** -// - -import java.io.DataInput; -import java.io.DataInputStream; -import java.io.DataOutput; -import java.io.DataOutputStream; -import java.io.IOException; -import java.io.InputStream; -import java.io.OutputStream; -import java.io.Serializable; -import java.text.NumberFormat; - -/** - * This class is designed to provide basic statistics collection. - * For each instance of this object statistics and be added to it - * then the sum, mean, std dev, min and max can be gathered at the - * end. To reuse this object, a clear method can be called to reset - * the statistics. - */ -public class Stat implements Serializable { - - /** - * Add a number to the statistics collector. - * doubles are used for all collections. - * - * @param x number added to the statistics. - */ - public void addNumber(int x) { - addNumber((double) x); - } - - /** - * Add a number to the statistics collector. - * doubles are used for all collections. - * - * @param x number added to the statistics. - */ - public void addNumber(float x) { - addNumber((double) x); - } - - /** - * Add a number to the statistics collector. - * doubles are used for all collections. - * - * @param x number added to the statistics. - */ - public synchronized void addNumber(double x) { - if (_max < x) { - _max = x; - } - if (_min > x) { - _min = x; - } - - _sum += x; - _sumOfSq += (x * x); - _number++; - - return; - } - - - /** - * Clear the statistics counters... - */ - public void clear() { - _max = 0; - _min = Double.MAX_VALUE; - _number = 0; - _mean = 0; - _stdDev = 0; - _sum = 0; - _sumOfSq = 0; - } - - - /** - * Create a string representation of the - * statistics collected so far. NOTE this - * is formatted and may not suit all needs - * and thus the user should just call the - * needed methods to get mean, std dev, etc. - * and format the data as needed. - * - * @return String Java string formatted output of results. - */ - public String toString() { - return toString(false); - } - - - /** - * Create a string representation of the - * statistics collected so far. The results - * are formatted in percentage format if - * passed in true, otherwise the results - * are the same as the toString call. NOTE this - * is formatted and may not suit all needs - * and thus the user should just call the - * needed methods to get mean, std dev, etc. - * and format the data as needed. - * - * @param percent Format as percentages if set to true. - * @return String Java string formatted output of results. - */ - public String toString(boolean percent) { - calculate(); - NumberFormat nf = NumberFormat.getInstance(); - nf.setMaximumFractionDigits(4); - - if (_number > 1) { - StringBuffer results = new StringBuffer(); - if (percent) { - results.append("Number:" + nf.format(_number * 100) + "%"); - } else { - results.append("Number:" + nf.format(_number)); - } - - if (percent) { - results.append(" Max:" + nf.format(_max * 100) + "%"); - } else { - results.append(" Max:" + nf.format(_max)); - } - - if (percent) { - results.append(" Min:" + nf.format(_min * 100) + "%"); - } else { - results.append(" Min:" + nf.format(_min)); - } - - if (percent) { - results.append(" Mean:" + nf.format(_mean * 100) + "%"); - } else { - results.append(" Mean:" + nf.format(_mean)); - } - - results.append(" Sum:" + nf.format(_sum)); - results.append(" STD:" + nf.format(_stdDev)); - return results.toString(); - } else if (_number == 1) { - if (percent) { - return ("Number:" + nf.format(_sum * 100) + "%"); - } else { - return ("Number:" + nf.format(_sum)); - } - } else { - return ("Number: N/A"); - } - } - - - private void calculate() { - getMean(); - getStandardDev(); - } - - - /** - * Get the max data element added to the statistics - * object so far. - * - * @return double - Maximum entry added so far. - */ - public double getMax() { - return _max; - } - - - /** - * Get the min data element added to the statistics - * object so far. - * - * @return double - Min entry added so far. - */ - public double getMin() { - return _min; - } - - - /** - * Get the number of data elements added to the statistics - * object so far. - * - * @return double - Number of entries added so far. - */ - public long getNumberOfElements() { - return _number; - } - - - /** - * Get the average or mean of data elements added to the - * statistics object so far. - * - * @return double - Mean of entries added so far. - */ - public double getMean() { - if (_number > 0) { - _mean = _sum / _number; - } - return _mean; - } - - /** - * Get the ratio of the sum of elements divided by the number - * of elements added * 100 - * - * @return double - Percent of entries added so far. - */ - public double getPercent() { - if (_number > 0) { - _mean = _sum / _number; - } - _mean = _mean * 100; - return _mean; - } - - - /** - * Get the sum or mean of data elements added to the - * statistics object so far. - * - * @return double - Sum of entries added so far. - */ - public double getSum() { - return _sum; - } - - - /** - * Get the sum of the squares of the data elements added - * to the statistics object so far. - * - * @return double - Sum of the squares of the entries added so far. - */ - public double getSumOfSq() { - return _sumOfSq; - } - - - /** - * Get the standard deviation of the data elements added - * to the statistics object so far. - * - * @return double - Sum of the standard deviation of the entries added so far. - */ - public double getStandardDev() { - if (_number > 1) { - _stdDev = Math.sqrt((_sumOfSq - ((_sum * _sum) / _number)) / (_number - 1)); - } - return _stdDev; - } - - - /** - * Read the data from the InputStream so it can be used to populate - * the current objects state. - * - * @param in java.io.InputStream to write to. - * @throws IOException - */ - public void readFromDataInput(InputStream in) throws IOException { - DataInput di = new DataInputStream(in); - readFromDataInput(di); - return; - } - - - /** - * Read the data from the DataInput so it can be used to populate - * the current objects state. - * - * @param in java.io.InputStream to write to. - * @throws IOException - */ - public void readFromDataInput(DataInput in) throws IOException { - _max = in.readDouble(); - _min = in.readDouble(); - _number = in.readLong(); - _mean = in.readDouble(); - _stdDev = in.readDouble(); - _sum = in.readDouble(); - _sumOfSq = in.readDouble(); - return; - } - - - /** - * Write the data to the output steam so it can be streamed to an - * other process, wire or storage median in a format that another Stats - * object can read. - * - * @param out java.io.OutputStream to write to. - * @throws IOException - */ - public void writeToDataOutput(OutputStream out) throws IOException { - DataOutput dout = new DataOutputStream(out); - writeToDataOutput(dout); - return; - - } - - - /** - * Write the data to the data output object so it can be written to an - * other process, wire or storage median in a format that another Stats - * object can read. - * - * @param out java.io.DataOutput to write to. - * @throws IOException - */ - public void writeToDataOutput(DataOutput out) throws IOException { - out.writeDouble(_max); - out.writeDouble(_min); - out.writeLong(_number); - out.writeDouble(_mean); - out.writeDouble(_stdDev); - out.writeDouble(_sum); - out.writeDouble(_sumOfSq); - return; - } - - - // ************************************ - private static final long serialVersionUID = 1L; - private double _max = 0 ; - private double _min = Double.MAX_VALUE ; - private long _number = 0 ; - private double _mean = 0 ; - private double _stdDev = 0 ; - private double _sum = 0 ; - private double _sumOfSq ; -} - http://git-wip-us.apache.org/repos/asf/aurora/blob/06ddaadb/commons/src/main/java/com/twitter/common/util/StateMachine.java ---------------------------------------------------------------------- diff --git a/commons/src/main/java/com/twitter/common/util/StateMachine.java b/commons/src/main/java/com/twitter/common/util/StateMachine.java deleted file mode 100644 index 1f2916e..0000000 --- a/commons/src/main/java/com/twitter/common/util/StateMachine.java +++ /dev/null @@ -1,583 +0,0 @@ -/** - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package com.twitter.common.util; - -import java.util.Arrays; -import java.util.List; -import java.util.Set; -import java.util.concurrent.locks.Lock; -import java.util.concurrent.locks.ReadWriteLock; -import java.util.concurrent.locks.ReentrantReadWriteLock; -import java.util.logging.Logger; - -import com.google.common.base.Function; -import com.google.common.base.Preconditions; -import com.google.common.base.Predicate; -import com.google.common.base.Predicates; -import com.google.common.collect.HashMultimap; -import com.google.common.collect.ImmutableSet; -import com.google.common.collect.Iterables; -import com.google.common.collect.Lists; -import com.google.common.collect.Multimap; - -import org.apache.commons.lang.builder.HashCodeBuilder; - -import com.twitter.common.base.Closure; -import com.twitter.common.base.Closures; -import com.twitter.common.base.ExceptionalSupplier; - -import static com.google.common.base.Preconditions.checkArgument; -import static com.google.common.base.Preconditions.checkNotNull; -import static com.twitter.common.base.MorePreconditions.checkNotBlank; - -/** - * Represents a state machine that is not necessarily a Finite State Machine. - * The caller may configure the state machine to permit only known state transitions, or to only - * disallow known state transitions (and permit unknown transitions). - * - * @param <T> THe type of objects that the caller uses to represent states. - * - * TODO(William Farner): Consider merging the stats-tracking ala PipelineStats into this. - */ -public class StateMachine<T> { - private static final Logger LOG = Logger.getLogger(StateMachine.class.getName()); - - private final String name; - - // Stores mapping from states to the states that the machine is allowed to transition into. - private final Multimap<T, T> stateTransitions; - - private final Closure<Transition<T>> transitionCallback; - private final boolean throwOnBadTransition; - - private volatile T currentState; - private final Lock readLock; - private final Lock writeLock; - - - private StateMachine(String name, - T initialState, - Multimap<T, T> stateTransitions, - Closure<Transition<T>> transitionCallback, - boolean throwOnBadTransition) { - this.name = name; - this.currentState = initialState; - this.stateTransitions = stateTransitions; - this.transitionCallback = transitionCallback; - this.throwOnBadTransition = throwOnBadTransition; - - ReadWriteLock stateLock = new ReentrantReadWriteLock(true /* fair */); - readLock = stateLock.readLock(); - writeLock = stateLock.writeLock(); - } - - /** - * Gets the name of this state machine. - * - * @return The state machine name. - */ - public String getName() { - return name; - } - - /** - * Fetches the state that the machine is currently in. - * - * @return Current state. - */ - public T getState() { - return currentState; - } - - /** - * Checks that the current state is the {@code expectedState} and throws if it is not. - * - * @param expectedState The expected state - * @throws IllegalStateException if the current state is not the {@code expectedState}. - */ - public void checkState(T expectedState) { - checkState(ImmutableSet.of(expectedState)); - } - - /** - * Checks that the current state is one of the {@code allowedStates} and throws if it is not. - * - * @param allowedStates The allowed states. - * @throws IllegalStateException if the current state is not the {@code expectedState}. - */ - public void checkState(Set<T> allowedStates) { - checkNotNull(allowedStates); - checkArgument(!allowedStates.isEmpty(), "At least one possible state must be provided."); - - readLock.lock(); - try { - if (!allowedStates.contains(currentState)) { - throw new IllegalStateException( - String.format("In state %s, expected to be in %s.", currentState, allowedStates)); - } - } finally { - readLock.unlock(); - } - } - - /** - * Executes the supplied {@code work} if the state machine is in the {@code expectedState}, - * postponing any concurrently requested {@link #transition(Object)} until after the execution of - * the work. - * - * @param expectedState The expected state the work should be performed in. - * @param work The work to perform in the {@code expectedState}. - * @param <O> The type returned by the unit of work. - * @param <E> The type of exception that may be thrown by the unit of work. - * @return The result of the unit of work if the current state is the {@code expectedState}. - * @throws IllegalStateException if the current state is not the {@code expectedState}. - * @throws E if the unit of work throws. - */ - public <O, E extends Exception> O doInState(T expectedState, ExceptionalSupplier<O, E> work) - throws E { - - checkNotNull(expectedState); - checkNotNull(work); - - readLock.lock(); - try { - checkState(expectedState); - return work.get(); - } finally { - readLock.unlock(); - } - } - - /** - * Transitions the machine into state {@code nextState}. - * - * @param nextState The state to move into. - * @throws IllegalStateTransitionException If the state transition is not allowed. - * @return {@code true} if the transition was allowed, {@code false} otherwise. - */ - public boolean transition(T nextState) throws IllegalStateTransitionException { - boolean transitionAllowed = false; - - T currentCopy = currentState; - - writeLock.lock(); - try { - if (stateTransitions.containsEntry(currentState, nextState)) { - currentState = nextState; - transitionAllowed = true; - } else if (throwOnBadTransition) { - throw new IllegalStateTransitionException( - String.format("State transition from %s to %s is not allowed.", currentState, - nextState)); - } - } finally { - writeLock.unlock(); - } - - transitionCallback.execute(new Transition<T>(currentCopy, nextState, transitionAllowed)); - return transitionAllowed; - } - - public static class IllegalStateTransitionException extends IllegalStateException { - public IllegalStateTransitionException(String msg) { - super(msg); - } - } - - /** - * Convenience method to create a builder object. - * - * @param <T> Type of builder to create. - * @param name Name of the state machine to create a builder for. - * @return New builder. - */ - public static <T> Builder<T> builder(String name) { - return new Builder<T>(name); - } - - /** - * A state and its allowed transitions (if any) and (optional) callback. - * - * @param <T> State type. - */ - public static class Rule<T> { - private final T from; - private final Set<T> to; - private final Closure<Transition<T>> callback; - - private Rule(T from) { - this(from, ImmutableSet.<T>of()); - } - - private Rule(T from, Set<T> to) { - this(from, to, Closures.<Transition<T>>noop()); - } - - private Rule(T from, Set<T> to, Closure<Transition<T>> callback) { - this.from = checkNotNull(from); - this.to = checkNotNull(to); - this.callback = checkNotNull(callback); - } - - /** - * Associates a callback to be triggered after any attempt to transition from this state is - * made. - * - * @param callback Callback to signal. - * @return A new rule that is identical to this rule, but with the provided - * callback - */ - public Rule<T> withCallback(Closure<Transition<T>> callback) { - return new Rule<T>(from, to, callback); - } - - /** - * A helper class when building a transition rule, to define the allowed transitions. - * - * @param <T> State type. - */ - public static class AllowedTransition<T> { - private final Rule<T> rule; - - private AllowedTransition(Rule<T> rule) { - this.rule = rule; - } - - /** - * Associates a single allowed transition with this state. - * - * @param state Allowed transition state. - * @return A new rule that identical to the original, but only allowing a transition to the - * provided state. - */ - public Rule<T> to(T state) { - return new Rule<T>(rule.from, ImmutableSet.<T>of(state), rule.callback); - } - - /** - * Associates multiple transitions with this state. - * - * @param state An allowed transition state. - * @param additionalStates Additional states that may be transitioned to. - * @return A new rule that identical to the original, but only allowing a transition to the - * provided states. - */ - public Rule<T> to(T state, T... additionalStates) { - return new Rule<T>(rule.from, ImmutableSet.copyOf(Lists.asList(state, additionalStates))); - } - - /** - * Allows no transitions to be performed from this state. - * - * @return The original rule. - */ - public Rule<T> noTransitions() { - return rule; - } - } - - /** - * Creates a new transition rule. - * - * @param state State to create and associate transitions with. - * @param <T> State type. - * @return A new transition rule builder. - */ - public static <T> AllowedTransition<T> from(T state) { - return new AllowedTransition<T>(new Rule<T>(state)); - } - } - - /** - * Builder to create a state machine. - * - * @param <T> - */ - public static class Builder<T> { - private final String name; - private T initialState; - private final Multimap<T, T> stateTransitions = HashMultimap.create(); - private final List<Closure<Transition<T>>> transitionCallbacks = Lists.newArrayList(); - private boolean throwOnBadTransition = true; - - public Builder(String name) { - this.name = checkNotBlank(name); - } - - /** - * Sets the initial state for the state machine. - * - * @param state Initial state. - * @return A reference to the builder. - */ - public Builder<T> initialState(T state) { - checkNotNull(state); - initialState = state; - return this; - } - - /** - * Adds a state and its allowed transitions. - * - * @param rule The state and transition rule to add. - * @return A reference to the builder. - */ - public Builder<T> addState(Rule<T> rule) { - return addState(rule.callback, rule.from, rule.to); - } - - /** - * Adds a state and its allowed transitions. - * At least one transition state must be added, it is not necessary to explicitly add states - * that have no allowed transitions (terminal states). - * - * @param callback Callback to notify of any transition attempted from the state. - * @param state State to add. - * @param transitionStates Allowed transitions from {@code state}. - * @return A reference to the builder. - */ - public Builder<T> addState(Closure<Transition<T>> callback, T state, - Set<T> transitionStates) { - checkNotNull(callback); - checkNotNull(state); - - Preconditions.checkArgument(Iterables.all(transitionStates, Predicates.notNull())); - - stateTransitions.putAll(state, transitionStates); - - @SuppressWarnings("unchecked") - Predicate<Transition<T>> filter = Transition.from(state); - onTransition(filter, callback); - return this; - } - - /** - * Varargs version of {@link #addState(com.twitter.common.base.Closure, Object, java.util.Set)}. - * - * @param callback Callback to notify of any transition attempted from the state. - * @param state State to add. - * @param transitionStates Allowed transitions from {@code state}. - * @return A reference to the builder. - */ - public Builder<T> addState(Closure<Transition<T>> callback, T state, - T... transitionStates) { - Set<T> states = ImmutableSet.copyOf(transitionStates); - Preconditions.checkArgument(Iterables.all(states, Predicates.notNull())); - - return addState(callback, state, states); - } - - /** - * Adds a state and its allowed transitions. - * At least one transition state must be added, it is not necessary to explicitly add states - * that have no allowed transitions (terminal states). - * - * @param state State to add. - * @param transitionStates Allowed transitions from {@code state}. - * @return A reference to the builder. - */ - public Builder<T> addState(T state, T... transitionStates) { - return addState(Closures.<Transition<T>>noop(), state, transitionStates); - } - - private void onTransition(Predicate<Transition<T>> transitionFilter, - Closure<Transition<T>> handler) { - onAnyTransition(Closures.filter(transitionFilter, handler)); - } - - /** - * Adds a callback to be executed for every state transition, including invalid transitions - * that are attempted. - * - * @param handler Callback to notify of transition attempts. - * @return A reference to the builder. - */ - public Builder<T> onAnyTransition(Closure<Transition<T>> handler) { - transitionCallbacks.add(handler); - return this; - } - - /** - * Adds a log message for every state transition that is attempted. - * - * @return A reference to the builder. - */ - public Builder<T> logTransitions() { - return onAnyTransition(new Closure<Transition<T>>() { - @Override public void execute(Transition<T> transition) { - LOG.info(name + " state machine transition " + transition); - } - }); - } - - /** - * Allows the caller to specify whether {@link IllegalStateTransitionException} should be thrown - * when a bad state transition is attempted (the default behavior). - * - * @param throwOnBadTransition Whether an exception should be thrown when a bad state transition - * is attempted. - * @return A reference to the builder. - */ - public Builder<T> throwOnBadTransition(boolean throwOnBadTransition) { - this.throwOnBadTransition = throwOnBadTransition; - return this; - } - - /** - * Builds the state machine. - * - * @return A reference to the prepared state machine. - */ - public StateMachine<T> build() { - Preconditions.checkState(initialState != null, "Initial state must be specified."); - checkArgument(!stateTransitions.isEmpty(), "No state transitions were specified."); - return new StateMachine<T>(name, - initialState, - stateTransitions, - Closures.combine(transitionCallbacks), - throwOnBadTransition); - } - } - - /** - * Representation of a state transition. - * - * @param <T> State type. - */ - public static class Transition<T> { - private final T from; - private final T to; - private final boolean allowed; - - public Transition(T from, T to, boolean allowed) { - this.from = checkNotNull(from); - this.to = checkNotNull(to); - this.allowed = allowed; - } - - private static <T> Function<Transition<T>, T> from() { - return new Function<Transition<T>, T>() { - @Override public T apply(Transition<T> transition) { - return transition.from; - } - }; - } - - private static <T> Function<Transition<T>, T> to() { - return new Function<Transition<T>, T>() { - @Override public T apply(Transition<T> transition) { - return transition.to; - } - }; - } - - private static <T> Predicate<Transition<T>> oneSideFilter( - Function<Transition<T>, T> extractor, final T... states) { - checkArgument(Iterables.all(Arrays.asList(states), Predicates.notNull())); - - return Predicates.compose(Predicates.in(ImmutableSet.copyOf(states)), extractor); - } - - /** - * Creates a predicate that returns {@code true} for transitions from the given states. - * - * @param states States to filter on. - * @param <T> State type. - * @return A from-state filter. - */ - public static <T> Predicate<Transition<T>> from(final T... states) { - return oneSideFilter(Transition.<T>from(), states); - } - - /** - * Creates a predicate that returns {@code true} for transitions to the given states. - * - * @param states States to filter on. - * @param <T> State type. - * @return A to-state filter. - */ - public static <T> Predicate<Transition<T>> to(final T... states) { - return oneSideFilter(Transition.<T>to(), states); - } - - /** - * Creates a predicate that returns {@code true} for a specific state transition. - * - * @param from From state. - * @param to To state. - * @param <T> State type. - * @return A state transition filter. - */ - public static <T> Predicate<Transition<T>> transition(final T from, final T to) { - @SuppressWarnings("unchecked") - Predicate<Transition<T>> fromFilter = from(from); - @SuppressWarnings("unchecked") - Predicate<Transition<T>> toFilter = to(to); - return Predicates.and(fromFilter, toFilter); - } - - public T getFrom() { - return from; - } - - public T getTo() { - return to; - } - - public boolean isAllowed() { - return allowed; - } - - /** - * Checks whether this transition represents a state change, which means that the 'to' state is - * not equal to the 'from' state, and the transition is allowed. - * - * @return {@code true} if the state was changed, {@code false} otherwise. - */ - public boolean isValidStateChange() { - return isAllowed() && !from.equals(to); - } - - @Override - public boolean equals(Object o) { - if (!(o instanceof Transition)) { - return false; - } - - if (o == this) { - return true; - } - - Transition<?> other = (Transition) o; - return from.equals(other.from) && to.equals(other.to); - } - - @Override - public int hashCode() { - return new HashCodeBuilder() - .append(from) - .append(to) - .toHashCode(); - } - - @Override - public String toString() { - String str = from.toString() + " -> " + to.toString(); - if (!isAllowed()) { - str += " (not allowed)"; - } - return str; - } - } -} http://git-wip-us.apache.org/repos/asf/aurora/blob/06ddaadb/commons/src/main/java/com/twitter/common/util/Timer.java ---------------------------------------------------------------------- diff --git a/commons/src/main/java/com/twitter/common/util/Timer.java b/commons/src/main/java/com/twitter/common/util/Timer.java deleted file mode 100644 index 32fca24..0000000 --- a/commons/src/main/java/com/twitter/common/util/Timer.java +++ /dev/null @@ -1,71 +0,0 @@ -/** - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package com.twitter.common.util; - -import com.twitter.common.base.Commands; -import com.twitter.common.base.ExceptionalCommand; -import com.twitter.common.base.ExceptionalSupplier; -import com.twitter.common.stats.SlidingStats; - -/** - * A utility for timing blocks of code. - * - * <p>TODO(John Sirois): consider instead: - * <T, E extends Exception> Pair<T, Long> doTimed(ExceptionalSupplier<T, E> timedWork) throws E - * or a subinterface of Command/Closure/Supplier/Function that exposes a timing method as other ways - * to factor in timing. - * - * @author John Sirois - */ -public final class Timer { - - /** - * Times the block of code encapsulated by {@code timedWork} recoding the result in {@code stat}. - * - * @param stat the stat to record the timing with - * @param timedWork the code to time - * @param <E> the type of exception {@code timedWork} may throw - * @throws E if {@code timedWork} throws - */ - public static <E extends Exception> void doTimed(SlidingStats stat, - final ExceptionalCommand<E> timedWork) throws E { - doTimed(stat, Commands.asSupplier(timedWork)); - } - - /** - * Times the block of code encapsulated by {@code timedWork} recoding the result in {@code stat}. - * - * @param stat the stat to record the timing with - * @param timedWork the code to time - * @param <T> the type of result {@code timedWork} returns - * @param <E> the type of exception {@code timedWork} may throw - * @return the result of {@code timedWork} if it completes normally - * @throws E if {@code timedWork} throws - */ - public static <T, E extends Exception> T doTimed(SlidingStats stat, - ExceptionalSupplier<T, E> timedWork) throws E { - StartWatch timer = new StartWatch(); - timer.start(); - try { - return timedWork.get(); - } finally { - timer.stop(); - stat.accumulate(timer.getTime()); - } - } - - private Timer() { - // utility - } -} http://git-wip-us.apache.org/repos/asf/aurora/blob/06ddaadb/commons/src/main/java/com/twitter/common/util/TruncatedBinaryBackoff.java ---------------------------------------------------------------------- diff --git a/commons/src/main/java/com/twitter/common/util/TruncatedBinaryBackoff.java b/commons/src/main/java/com/twitter/common/util/TruncatedBinaryBackoff.java deleted file mode 100644 index 23da467..0000000 --- a/commons/src/main/java/com/twitter/common/util/TruncatedBinaryBackoff.java +++ /dev/null @@ -1,74 +0,0 @@ -/** - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package com.twitter.common.util; - -import com.google.common.base.Preconditions; -import com.twitter.common.quantity.Amount; -import com.twitter.common.quantity.Time; - -/** - * A BackoffStrategy that implements truncated binary exponential backoff. - */ -public class TruncatedBinaryBackoff implements BackoffStrategy { - private final long initialBackoffMs; - private final long maxBackoffIntervalMs; - private final boolean stopAtMax; - - /** - * Creates a new TruncatedBinaryBackoff that will start by backing off for {@code initialBackoff} - * and then backoff of twice as long each time its called until reaching the {@code maxBackoff} at - * which point shouldContinue() will return false and any future backoffs will always wait for - * that amount of time. - * - * @param initialBackoff the intial amount of time to backoff - * @param maxBackoff the maximum amount of time to backoff - * @param stopAtMax whether shouldContinue() returns false when the max is reached - */ - public TruncatedBinaryBackoff(Amount<Long, Time> initialBackoff, - Amount<Long, Time> maxBackoff, boolean stopAtMax) { - Preconditions.checkNotNull(initialBackoff); - Preconditions.checkNotNull(maxBackoff); - Preconditions.checkArgument(initialBackoff.getValue() > 0); - Preconditions.checkArgument(maxBackoff.compareTo(initialBackoff) >= 0); - initialBackoffMs = initialBackoff.as(Time.MILLISECONDS); - maxBackoffIntervalMs = maxBackoff.as(Time.MILLISECONDS); - this.stopAtMax = stopAtMax; - } - - /** - * Same as main constructor, but this will always return true from shouldContinue(). - * - * @param initialBackoff the intial amount of time to backoff - * @param maxBackoff the maximum amount of time to backoff - */ - public TruncatedBinaryBackoff(Amount<Long, Time> initialBackoff, Amount<Long, Time> maxBackoff) { - this(initialBackoff, maxBackoff, false); - } - - @Override - public long calculateBackoffMs(long lastBackoffMs) { - Preconditions.checkArgument(lastBackoffMs >= 0); - long backoff = (lastBackoffMs == 0) ? initialBackoffMs - : Math.min(maxBackoffIntervalMs, lastBackoffMs * 2); - return backoff; - } - - @Override - public boolean shouldContinue(long lastBackoffMs) { - Preconditions.checkArgument(lastBackoffMs >= 0); - boolean stop = stopAtMax && (lastBackoffMs >= maxBackoffIntervalMs); - - return !stop; - } -} http://git-wip-us.apache.org/repos/asf/aurora/blob/06ddaadb/commons/src/main/java/com/twitter/common/util/caching/Cache.java ---------------------------------------------------------------------- diff --git a/commons/src/main/java/com/twitter/common/util/caching/Cache.java b/commons/src/main/java/com/twitter/common/util/caching/Cache.java deleted file mode 100644 index b8e437c..0000000 --- a/commons/src/main/java/com/twitter/common/util/caching/Cache.java +++ /dev/null @@ -1,46 +0,0 @@ -/** - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package com.twitter.common.util.caching; - -/** - * Definition of basic caching functionality. Cache keys and values are expected to always be - * valid, non-null values. - * - * @author William Farner - */ -public interface Cache<K, V> { - - /** - * Fetches a value from the cache. - * - * @param key The key for the value to fetch, must not be {@code null}. - * @return The cached value corresponding with {@code key}, or {@code null} if no entry exists. - */ - public V get(K key); - - /** - * Stores a key-value pair in the cache. - * - * @param key The key to store, must not be {@code null}. - * @param value The value to store, must not be {@code null}. - */ - public void put(K key, V value); - - /** - * Deletes an entry from the cache. - * - * @param key Key for the value to delete, must not be {@code null}. - */ - public void delete(K key); -} http://git-wip-us.apache.org/repos/asf/aurora/blob/06ddaadb/commons/src/main/java/com/twitter/common/util/caching/CachingMethodProxy.java ---------------------------------------------------------------------- diff --git a/commons/src/main/java/com/twitter/common/util/caching/CachingMethodProxy.java b/commons/src/main/java/com/twitter/common/util/caching/CachingMethodProxy.java deleted file mode 100644 index f44b278..0000000 --- a/commons/src/main/java/com/twitter/common/util/caching/CachingMethodProxy.java +++ /dev/null @@ -1,262 +0,0 @@ -/** - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package com.twitter.common.util.caching; - -import com.google.common.base.Function; -import com.google.common.base.Preconditions; -import com.google.common.base.Predicate; -import com.google.common.base.Predicates; -import com.google.common.collect.ImmutableMap; -import com.google.common.collect.Maps; - -import java.lang.reflect.InvocationHandler; -import java.lang.reflect.InvocationTargetException; -import java.lang.reflect.Method; -import java.lang.reflect.Proxy; -import java.util.Arrays; -import java.util.List; -import java.util.Map; - -/** - * A proxy class that handles caching of return values for method calls to a wrapped object. - * - * Example usage: - * - * Foo uncached = new Foo(); - * CachingMethodProxy<Foo> methodProxy = CachingMethodProxy.proxyFor(uncached, Foo.class); - * Foo foo = methodProxy.getCachingProxy(); - * methodProxy.cache(foo.doBar(), lruCache1) - * .cache(foo.doBaz(), lruCache2) - * .prepare(); - * - * @author William Farner - */ -public class CachingMethodProxy<T> { - - // Dummy return values to return when in recording state. - private static final Map<Class<?>, Object> EMPTY_RETURN_VALUES = - ImmutableMap.<Class<?>, Object>builder() - .put(Boolean.TYPE, Boolean.FALSE) - .put(Byte.TYPE, Byte.valueOf((byte) 0)) - .put(Short.TYPE, Short.valueOf((short) 0)) - .put(Character.TYPE, Character.valueOf((char)0)) - .put(Integer.TYPE, Integer.valueOf(0)) - .put(Long.TYPE, Long.valueOf(0)) - .put(Float.TYPE, Float.valueOf(0)) - .put(Double.TYPE, Double.valueOf(0)) - .build(); - private static final Map<Class<?>, Class<?>> AUTO_BOXING_MAP = - ImmutableMap.<Class<?>, Class<?>>builder() - .put(Boolean.TYPE, Boolean.class) - .put(Byte.TYPE, Byte.class) - .put(Short.TYPE, Short.class) - .put(Character.TYPE, Character.class) - .put(Integer.TYPE, Integer.class) - .put(Long.TYPE, Long.class) - .put(Float.TYPE, Float.class) - .put(Double.TYPE, Double.class) - .build(); - - // The uncached resource, whose method calls are deemed to be expensive and cacheable. - private final T uncached; - - // The methods that are cached, and the caches themselves. - private final Map<Method, MethodCache> methodCaches = Maps.newHashMap(); - private final Class<T> type; - - private Method lastMethodCall = null; - private boolean recordMode = true; - - /** - * Creates a new caching method proxy that will wrap an object and cache for the provided methods. - * - * @param uncached The uncached object that will be reverted to when a cache entry is not present. - */ - private CachingMethodProxy(T uncached, Class<T> type) { - this.uncached = Preconditions.checkNotNull(uncached); - this.type = Preconditions.checkNotNull(type); - Preconditions.checkArgument(type.isInterface(), "The proxied type must be an interface."); - } - - private static Object invokeMethod(Object subject, Method method, Object[] args) - throws Throwable { - try { - return method.invoke(subject, args); - } catch (IllegalAccessException e) { - throw new RuntimeException("Cannot access " + subject.getClass() + "." + method, e); - } catch (InvocationTargetException e) { - throw e.getCause(); - } - } - - /** - * A cached method and its caching control structures. - * - * @param <K> Cache key type. - * @param <V> Cache value type, expected to match the return type of the method. - */ - private static class MethodCache<K, V> { - private final Method method; - private final Cache<K, V> cache; - private final Function<Object[], K> keyBuilder; - private final Predicate<V> entryFilter; - - MethodCache(Method method, Cache<K, V> cache, Function<Object[], K> keyBuilder, - Predicate<V> entryFilter) { - this.method = method; - this.cache = cache; - this.keyBuilder = keyBuilder; - this.entryFilter = entryFilter; - } - - V doInvoke(Object uncached, Object[] args) throws Throwable { - K key = keyBuilder.apply(args); - - V cachedValue = cache.get(key); - - if (cachedValue != null) return cachedValue; - - Object fetched = invokeMethod(uncached, method, args); - - if (fetched == null) return null; - - @SuppressWarnings("unchecked") - V typedValue = (V) fetched; - - if (entryFilter.apply(typedValue)) cache.put(key, typedValue); - - return typedValue; - } - } - - /** - * Creates a new builder for the given type. - * - * @param uncached The uncached object that should be insulated by caching. - * @param type The interface that a proxy should be created for. - * @param <T> Type parameter to the proxied class. - * @return A new builder. - */ - public static <T> CachingMethodProxy<T> proxyFor(T uncached, Class<T> type) { - return new CachingMethodProxy<T>(uncached, type); - } - - @SuppressWarnings("unchecked") - public T getCachingProxy() { - return (T) Proxy.newProxyInstance(type.getClassLoader(), new Class[] { type }, - new InvocationHandler() { - @Override public Object invoke(Object proxy, Method method, Object[] args) - throws Throwable { - return doInvoke(method, args); - } - }); - } - - private Object doInvoke(Method method, Object[] args) throws Throwable { - return recordMode ? recordCall(method) : cacheRequest(method, args); - } - - private Object recordCall(Method method) { - Preconditions.checkArgument(method.getReturnType() != Void.TYPE, - "Void return methods cannot be cached: " + method); - Preconditions.checkArgument(method.getParameterTypes().length > 0, - "Methods with zero arguments cannot be cached: " + method); - Preconditions.checkState(lastMethodCall == null, - "No cache instructions provided for call to: " + lastMethodCall); - - lastMethodCall = method; - - Class<?> returnType = method.getReturnType(); - return returnType.isPrimitive() ? EMPTY_RETURN_VALUES.get(returnType) : null; - } - - private Object cacheRequest(Method method, Object[] args) throws Throwable { - MethodCache cache = methodCaches.get(method); - - // Check if we are caching for this method. - if (cache == null) return invokeMethod(uncached, method, args); - - return cache.doInvoke(uncached, args); - } - - /** - * Instructs the proxy that cache setup is complete, and the proxy instance should begin caching - * and delegating uncached calls. After this is called, any subsequent calls to any of the - * cache setup methods will result in an {@link IllegalStateException}. - */ - public void prepare() { - Preconditions.checkState(!methodCaches.isEmpty(), "At least one method must be cached."); - Preconditions.checkState(recordMode, "prepare() may only be invoked once."); - - recordMode = false; - } - - public <V> CachingMethodProxy<T> cache(V value, Cache<List, V> cache) { - return cache(value, cache, Predicates.<V>alwaysTrue()); - } - - public <V> CachingMethodProxy<T> cache(V value, Cache<List, V> cache, - Predicate<V> valueFilter) { - return cache(value, cache, DEFAULT_KEY_BUILDER, valueFilter); - } - - public <K, V> CachingMethodProxy<T> cache(V value, Cache<K, V> cache, - Function<Object[], K> keyBuilder) { - // Get the last method call and declare it the cached method. - return cache(value, cache, keyBuilder, Predicates.<V>alwaysTrue()); - } - - public <K, V> CachingMethodProxy<T> cache(V value, Cache<K, V> cache, - Function<Object[], K> keyBuilder, Predicate<V> valueFilter) { - Preconditions.checkNotNull(cache); - Preconditions.checkNotNull(keyBuilder); - Preconditions.checkNotNull(valueFilter); - - Preconditions.checkState(recordMode, "Cache setup is not allowed after prepare() is called."); - - // Get the last method call and declare it the cached method. - Preconditions.checkState(lastMethodCall != null, "No method call captured to be cached."); - - Class<?> returnType = lastMethodCall.getReturnType(); - - Preconditions.checkArgument(returnType != Void.TYPE, - "Cannot cache results from void method: " + lastMethodCall); - - if (returnType.isPrimitive()) { - // If a primitive type is returned, we need to make sure that the cache holds the boxed - // type for the primitive. - returnType = AUTO_BOXING_MAP.get(returnType); - } - - // TODO(William Farner): Figure out a simple way to make this possible. Right now, since the proxy - // objects return null, we get a null here and can't check the type. - //Preconditions.checkArgument(value.getClass() == returnType, - // String.format("Cache value type '%s' does not match method return type '%s'", - // value.getClass(), lastMethodCall.getReturnType())); - - methodCaches.put(lastMethodCall, new MethodCache<K, V>(lastMethodCall, cache, keyBuilder, - valueFilter)); - - lastMethodCall = null; - - return this; - } - - private static final Function<Object[], List> DEFAULT_KEY_BUILDER = - new Function<Object[], List>() { - @Override public List apply(Object[] args) { - return Arrays.asList(args); - } - }; -} http://git-wip-us.apache.org/repos/asf/aurora/blob/06ddaadb/commons/src/main/java/com/twitter/common/util/caching/LRUCache.java ---------------------------------------------------------------------- diff --git a/commons/src/main/java/com/twitter/common/util/caching/LRUCache.java b/commons/src/main/java/com/twitter/common/util/caching/LRUCache.java deleted file mode 100644 index f0dd2d3..0000000 --- a/commons/src/main/java/com/twitter/common/util/caching/LRUCache.java +++ /dev/null @@ -1,170 +0,0 @@ -/** - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package com.twitter.common.util.caching; - -import com.google.common.base.Preconditions; -import com.google.common.collect.ImmutableList; -import com.twitter.common.base.Closure; -import com.twitter.common.base.MorePreconditions; -import com.twitter.common.collections.Pair; -import com.twitter.common.stats.Stats; - -import java.util.Collection; -import java.util.Collections; -import java.util.LinkedHashMap; -import java.util.Map; -import java.util.concurrent.atomic.AtomicLong; - -/** - * A cache with a fixed maximum size, evicting items that were used least-recently. - * WARNING: This is not thread-safe. If you wish to get a thread-safe version of a constructed - * LRUCache, you must wrap it with {@link Collections#synchronizedMap(java.util.Map)}. - * - * @author William Farner - */ -public class LRUCache<K, V> implements Cache<K, V> { - - private Map<K, V> map; - - private final AtomicLong accesses; - private final AtomicLong misses; - - /** - * Creates a new bounded cache with the given load factor. - * - * @param name Unique name for this cache. - * @param maxCapacity Maximum capacity for the cache, after which items will be evicted. - * @param loadFactor Load factor for the cache. - * @param makeSynchronized Whether the underlying map should be synchronized. - * @param evictionListener Listener to be notified when an element is evicted, or {@code null} if - * eviction notifications are not needed. - */ - private LRUCache(final String name, final int maxCapacity, float loadFactor, - boolean makeSynchronized, final Closure<Pair<K, V>> evictionListener) { - map = new LinkedHashMap<K, V>(maxCapacity, loadFactor, true /* Access order. */) { - @Override public boolean removeEldestEntry(Map.Entry<K, V> entry) { - boolean evict = size() > maxCapacity; - if (evict && evictionListener != null) { - evictionListener.execute(Pair.of(entry.getKey(), entry.getValue())); - } - return evict; - } - }; - - if (makeSynchronized) { - map = Collections.synchronizedMap(map); - } - - accesses = Stats.exportLong(name + "_lru_cache_accesses"); - misses = Stats.exportLong(name + "_lru_cache_misses"); - } - - public static <K, V> Builder<K, V> builder() { - return new Builder<K, V>(); - } - - public static class Builder<K, V> { - private String name = null; - - private int maxSize = 1000; - - // Sadly, LinkedHashMap doesn't expose this, so the default is pulled from the javadoc. - private float loadFactor = 0.75F; - - private boolean makeSynchronized = true; - - private Closure<Pair<K, V>> evictionListener = null; - - public Builder<K, V> name(String name) { - this.name = MorePreconditions.checkNotBlank(name); - return this; - } - - public Builder<K, V> maxSize(int maxSize) { - Preconditions.checkArgument(maxSize > 0); - this.maxSize = maxSize; - return this; - } - - public Builder<K, V> loadFactor(float loadFactor) { - this.loadFactor = loadFactor; - return this; - } - - public Builder<K, V> makeSynchronized(boolean makeSynchronized) { - this.makeSynchronized = makeSynchronized; - return this; - } - - public Builder<K, V> evictionListener(Closure<Pair<K, V>> evictionListener) { - this.evictionListener = evictionListener; - return this; - } - - public LRUCache<K, V> build() { - return new LRUCache<K, V>(name, maxSize, loadFactor, makeSynchronized, evictionListener); - } - } - - @Override - public V get(K key) { - accesses.incrementAndGet(); - V value = map.get(key); - if (value == null) { - misses.incrementAndGet(); - } - return value; - } - - @Override - public void put(K key, V value) { - map.put(key, value); - } - - @Override - public void delete(K key) { - map.remove(key); - } - - public int size() { - return map.size(); - } - - @Override - public String toString() { - return String.format("size: %d, accesses: %s, misses: %s", - map.size(), - accesses, - misses); - } - - public Collection<V> copyValues() { - synchronized(map) { - return ImmutableList.copyOf(map.values()); - } - } - - public long getAccesses() { - return accesses.longValue(); - } - - public long getMisses() { - return misses.longValue(); - } - - public double getHitRate() { - double numAccesses = accesses.longValue(); - return numAccesses == 0 ? 0 : (numAccesses - misses.longValue()) / numAccesses; - } -} http://git-wip-us.apache.org/repos/asf/aurora/blob/06ddaadb/commons/src/main/java/com/twitter/common/util/concurrent/BackingOffFutureTask.java ---------------------------------------------------------------------- diff --git a/commons/src/main/java/com/twitter/common/util/concurrent/BackingOffFutureTask.java b/commons/src/main/java/com/twitter/common/util/concurrent/BackingOffFutureTask.java deleted file mode 100644 index 6dab3b8..0000000 --- a/commons/src/main/java/com/twitter/common/util/concurrent/BackingOffFutureTask.java +++ /dev/null @@ -1,56 +0,0 @@ -/** - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package com.twitter.common.util.concurrent; - -import com.google.common.base.Preconditions; -import com.twitter.common.util.BackoffStrategy; - -import java.util.concurrent.Callable; -import java.util.concurrent.ScheduledExecutorService; -import java.util.concurrent.TimeUnit; - -/** - * A {@link RetryingFutureTask} that will resubmit itself to a work queue with a backoff. - * - * @author William Farner - */ -public class BackingOffFutureTask extends RetryingFutureTask { - private final ScheduledExecutorService executor; - private final BackoffStrategy backoffStrategy; - private long backoffMs = 0; - - /** - * Creates a new retrying future task that will execute a unit of work until successfully - * completed, or the retry limit has been reached. - * - * @param executor The executor service to resubmit the task to upon failure. - * @param callable The unit of work. The work is considered successful when {@code true} is - * returned. It may return {@code false} or throw an exception when - * unsueccessful. - * @param maxRetries The maximum number of times to retry the task. - * @param backoffStrategy Strategy to use for determining backoff duration. - */ - public BackingOffFutureTask(ScheduledExecutorService executor, Callable<Boolean> callable, - int maxRetries, BackoffStrategy backoffStrategy) { - super(executor, callable, maxRetries); - this.executor = executor; - this.backoffStrategy = Preconditions.checkNotNull(backoffStrategy); - } - - @Override - protected void retry() { - backoffMs = backoffStrategy.calculateBackoffMs(backoffMs); - executor.schedule(this, backoffMs, TimeUnit.MILLISECONDS); - } -} http://git-wip-us.apache.org/repos/asf/aurora/blob/06ddaadb/commons/src/main/java/com/twitter/common/util/concurrent/ExceptionHandlingExecutorService.java ---------------------------------------------------------------------- diff --git a/commons/src/main/java/com/twitter/common/util/concurrent/ExceptionHandlingExecutorService.java b/commons/src/main/java/com/twitter/common/util/concurrent/ExceptionHandlingExecutorService.java deleted file mode 100644 index 1208b7e..0000000 --- a/commons/src/main/java/com/twitter/common/util/concurrent/ExceptionHandlingExecutorService.java +++ /dev/null @@ -1,94 +0,0 @@ -/** - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package com.twitter.common.util.concurrent; - -import java.util.Collection; -import java.util.List; -import java.util.concurrent.Callable; -import java.util.concurrent.ExecutionException; -import java.util.concurrent.ExecutorService; -import java.util.concurrent.Future; -import java.util.concurrent.TimeUnit; -import java.util.concurrent.TimeoutException; - -import com.google.common.base.Function; -import com.google.common.base.Preconditions; -import com.google.common.base.Supplier; -import com.google.common.base.Throwables; -import com.google.common.collect.Collections2; - -/** - * An executor service that delegates to another executor service, invoking an uncaught - * exception handler if any exceptions are thrown in submitted work. - * - * @see MoreExecutors - */ -class ExceptionHandlingExecutorService extends ForwardingExecutorService<ExecutorService> { - private final Supplier<Thread.UncaughtExceptionHandler> handler; - - ExceptionHandlingExecutorService( - ExecutorService delegate, - Supplier<Thread.UncaughtExceptionHandler> handler) { - - super(delegate); - this.handler = Preconditions.checkNotNull(handler); - } - - @Override - public <T> Future<T> submit(Callable<T> task) { - return super.submit(TaskConverter.alertingCallable(task, handler)); - } - - @Override - public <T> Future<T> submit(Runnable task, T result) { - return super.submit(TaskConverter.alertingRunnable(task, handler), result); - } - - @Override - public Future<?> submit(Runnable task) { - return super.submit(TaskConverter.alertingRunnable(task, handler)); - } - - @Override - public <T> List<Future<T>> invokeAll( - Collection<? extends Callable<T>> tasks) throws InterruptedException { - - return super.invokeAll(TaskConverter.alertingCallables(tasks, handler)); - } - - @Override - public <T> List<Future<T>> invokeAll( - Collection<? extends Callable<T>> tasks, - long timeout, - TimeUnit unit) throws InterruptedException { - - return super.invokeAll(TaskConverter.alertingCallables(tasks, handler), timeout, unit); - } - - @Override - public <T> T invokeAny( - Collection<? extends Callable<T>> tasks) throws InterruptedException, ExecutionException { - - return super.invokeAny(TaskConverter.alertingCallables(tasks, handler)); - } - - @Override - public <T> T invokeAny( - Collection<? extends Callable<T>> tasks, - long timeout, - TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException { - - return super.invokeAny(TaskConverter.alertingCallables(tasks, handler), timeout, unit); - } -} http://git-wip-us.apache.org/repos/asf/aurora/blob/06ddaadb/commons/src/main/java/com/twitter/common/util/concurrent/ExceptionHandlingScheduledExecutorService.java ---------------------------------------------------------------------- diff --git a/commons/src/main/java/com/twitter/common/util/concurrent/ExceptionHandlingScheduledExecutorService.java b/commons/src/main/java/com/twitter/common/util/concurrent/ExceptionHandlingScheduledExecutorService.java deleted file mode 100644 index 474d612..0000000 --- a/commons/src/main/java/com/twitter/common/util/concurrent/ExceptionHandlingScheduledExecutorService.java +++ /dev/null @@ -1,121 +0,0 @@ -/** - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package com.twitter.common.util.concurrent; - -import java.util.Collection; -import java.util.List; -import java.util.concurrent.Callable; -import java.util.concurrent.ExecutionException; -import java.util.concurrent.Future; -import java.util.concurrent.ScheduledExecutorService; -import java.util.concurrent.ScheduledFuture; -import java.util.concurrent.TimeUnit; -import java.util.concurrent.TimeoutException; - -import com.google.common.base.Function; -import com.google.common.base.Supplier; -import com.google.common.base.Throwables; -import com.google.common.collect.Collections2; - -/** - * A scheduled executor service that delegates to another executor service, invoking an uncaught - * exception handler if any exceptions are thrown in submitted work. - * - * @see MoreExecutors - */ -class ExceptionHandlingScheduledExecutorService - extends ForwardingExecutorService<ScheduledExecutorService> - implements ScheduledExecutorService { - private final Supplier<Thread.UncaughtExceptionHandler> handler; - - /** - * Construct a {@link ScheduledExecutorService} with a supplier of - * {@link Thread.UncaughtExceptionHandler} that handles exceptions thrown from submitted work. - */ - ExceptionHandlingScheduledExecutorService( - ScheduledExecutorService delegate, - Supplier<Thread.UncaughtExceptionHandler> handler) { - super(delegate); - this.handler = handler; - } - - @Override - public ScheduledFuture<?> schedule(Runnable runnable, long delay, TimeUnit timeUnit) { - return delegate.schedule(TaskConverter.alertingRunnable(runnable, handler), delay, timeUnit); - } - - @Override - public <V> ScheduledFuture<V> schedule(Callable<V> callable, long delay, TimeUnit timeUnit) { - return delegate.schedule(TaskConverter.alertingCallable(callable, handler), delay, timeUnit); - } - - @Override - public ScheduledFuture<?> scheduleAtFixedRate( - Runnable runnable, long initialDelay, long period, TimeUnit timeUnit) { - return delegate.scheduleAtFixedRate( - TaskConverter.alertingRunnable(runnable, handler), initialDelay, period, timeUnit); - } - - @Override - public ScheduledFuture<?> scheduleWithFixedDelay( - Runnable runnable, long initialDelay, long delay, TimeUnit timeUnit) { - return delegate.scheduleWithFixedDelay( - TaskConverter.alertingRunnable(runnable, handler), initialDelay, delay, timeUnit); - } - - @Override - public <T> Future<T> submit(Callable<T> task) { - return delegate.submit(TaskConverter.alertingCallable(task, handler)); - } - - @Override - public <T> Future<T> submit(Runnable task, T result) { - return delegate.submit(TaskConverter.alertingRunnable(task, handler), result); - } - - @Override - public Future<?> submit(Runnable task) { - return delegate.submit(TaskConverter.alertingRunnable(task, handler)); - } - - @Override - public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) - throws InterruptedException { - return delegate.invokeAll(TaskConverter.alertingCallables(tasks, handler)); - } - - @Override - public <T> List<Future<T>> invokeAll( - Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) - throws InterruptedException { - return delegate.invokeAll(TaskConverter.alertingCallables(tasks, handler), timeout, unit); - } - - @Override - public <T> T invokeAny(Collection<? extends Callable<T>> tasks) - throws InterruptedException, ExecutionException { - return delegate.invokeAny(TaskConverter.alertingCallables(tasks, handler)); - } - - @Override - public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) - throws InterruptedException, ExecutionException, TimeoutException { - return delegate.invokeAny(TaskConverter.alertingCallables(tasks, handler), timeout, unit); - } - - @Override - public void execute(Runnable command) { - delegate.execute(TaskConverter.alertingRunnable(command, handler)); - } -}
