added synchronous future wrapper

git-svn-id: http://jclouds.googlecode.com/svn/trunk@1991 3d8758e0-26b5-11de-8745-db77d3ebf521

concurrent/src/main/java/org/jclouds/concurrent/FutureExceptionParser.java

@@ -1,6 +1,6 @@
 /**
  *
- * Copyright (C) 2009 Global Cloud Specialists, Inc. <info@globalcloudspecialists.com>
+ * Copyright (C) 2009 Cloud Conscious, LLC. <info@cloudconscious.com>
  *
  * ====================================================================
  * Licensed to the Apache Software Foundation (ASF) under one

concurrent/src/main/java/org/jclouds/concurrent/FutureFunctionCallable.java

@@ -1,6 +1,6 @@
 /**
  *
- * Copyright (C) 2009 Global Cloud Specialists, Inc. <info@globalcloudspecialists.com>
+ * Copyright (C) 2009 Cloud Conscious, LLC. <info@cloudconscious.com>
  *
  * ====================================================================
  * Licensed to the Apache Software Foundation (ASF) under one

concurrent/src/main/java/org/jclouds/concurrent/FutureFunctionWrapper.java

@@ -0,0 +1,84 @@
+/**
+ *
+ * Copyright (C) 2009 Cloud Conscious, LLC. <info@cloudconscious.com>
+ *
+ * ====================================================================
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you 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 org.jclouds.concurrent;
+
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.Future;
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.TimeoutException;
+
+import org.jclouds.logging.Logger;
+
+import com.google.common.base.Function;
+
+/**
+ * Transforms the result of a future once requested via get().
+ * 
+ * @author Adrian Cole
+ */
+public class FutureFunctionWrapper<F, T> implements Future<T>, Function<F, T> {
+
+   private final Future<? extends F> future;
+   private final Function<F, T> function;
+   private final Logger logger;
+
+   public FutureFunctionWrapper(Future<? extends F> future, Function<F, T> function) {
+      this(future, function, Logger.NULL);
+   }
+
+   public FutureFunctionWrapper(Future<? extends F> future, Function<F, T> function, Logger logger) {
+      this.future = future;
+      this.function = function;
+      this.logger = logger;
+   }
+
+   public T apply(F input) {
+      logger.debug("Processing intermediate result for: %s", input);
+      T result = function.apply(input);
+      logger.debug("Processed intermediate result for: %s", input);
+      return result;
+   }
+
+   public boolean cancel(boolean mayInterruptIfRunning) {
+      return future.cancel(mayInterruptIfRunning);
+   }
+
+   public T get() throws InterruptedException, ExecutionException {
+      return apply(future.get());
+   }
+
+   public T get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException,
+            TimeoutException {
+      return apply(future.get(timeout, unit));
+   }
+
+   public boolean isCancelled() {
+      return future.isCancelled();
+   }
+
+   public boolean isDone() {
+      return future.isDone();
+   }
+
+}

concurrent/src/main/java/org/jclouds/concurrent/RunnableFutureTask.java

@@ -1,6 +1,6 @@
 /**
  *
- * Copyright (C) 2009 Global Cloud Specialists, Inc. <info@globalcloudspecialists.com>
+ * Copyright (C) 2009 Cloud Conscious, LLC. <info@cloudconscious.com>
  *
  * ====================================================================
  * Licensed to the Apache Software Foundation (ASF) under one

concurrent/src/main/java/org/jclouds/concurrent/SingleThreadCompatible.java

@@ -1,6 +1,6 @@
 /**
  *
- * Copyright (C) 2009 Global Cloud Specialists, Inc. <info@globalcloudspecialists.com>
+ * Copyright (C) 2009 Cloud Conscious, LLC. <info@cloudconscious.com>
  *
  * ====================================================================
  * Licensed to the Apache Software Foundation (ASF) under one

concurrent/src/main/java/org/jclouds/concurrent/SingleThreaded.java

@@ -1,6 +1,6 @@
 /**
  *
- * Copyright (C) 2009 Global Cloud Specialists, Inc. <info@globalcloudspecialists.com>
+ * Copyright (C) 2009 Cloud Conscious, LLC. <info@cloudconscious.com>
  *
  * ====================================================================
  * Licensed to the Apache Software Foundation (ASF) under one

concurrent/src/main/java/org/jclouds/concurrent/WithinThreadExecutor.java

@@ -1,6 +1,6 @@
 /**
  *
- * Copyright (C) 2009 Global Cloud Specialists, Inc. <info@globalcloudspecialists.com>
+ * Copyright (C) 2009 Cloud Conscious, LLC. <info@cloudconscious.com>
  *
  * ====================================================================
  * Licensed to the Apache Software Foundation (ASF) under one

concurrent/src/main/java/org/jclouds/concurrent/WithinThreadExecutorService.java

@@ -1,6 +1,6 @@
 /**
  *
- * Copyright (C) 2009 Global Cloud Specialists, Inc. <info@globalcloudspecialists.com>
+ * Copyright (C) 2009 Cloud Conscious, LLC. <info@cloudconscious.com>
  *
  * ====================================================================
  * Licensed to the Apache Software Foundation (ASF) under one

concurrent/src/main/java/org/jclouds/logging/Logger.java

@@ -1,6 +1,6 @@
 /**
  *
- * Copyright (C) 2009 Global Cloud Specialists, Inc. <info@globalcloudspecialists.com>
+ * Copyright (C) 2009 Cloud Conscious, LLC. <info@cloudconscious.com>
  *
  * ====================================================================
  * Licensed to the Apache Software Foundation (ASF) under one

concurrent/src/main/java/org/jclouds/logging/NullLogger.java

@@ -1,6 +1,6 @@
 /**
  *
- * Copyright (C) 2009 Global Cloud Specialists, Inc. <info@globalcloudspecialists.com>
+ * Copyright (C) 2009 Cloud Conscious, LLC. <info@cloudconscious.com>
  *
  * ====================================================================
  * Licensed to the Apache Software Foundation (ASF) under one

concurrent/src/test/java/org/jclouds/concurrent/FutureExceptionParserTest.java

@@ -1,6 +1,6 @@
 /**
  *
- * Copyright (C) 2009 Global Cloud Specialists, Inc. <info@globalcloudspecialists.com>
+ * Copyright (C) 2009 Cloud Conscious, LLC. <info@cloudconscious.com>
  *
  * ====================================================================
  * Licensed to the Apache Software Foundation (ASF) under one