src/java/org/apache/cassandra/utils/FBUtilities.java
/**
     * Waits for the futures to complete.
     * @param timeout the timeout expressed in <code>TimeUnit</code> units
     * @param timeUnit TimeUnit
     * @throws TimeoutException if the waiting time exceeds <code>timeout</code>
     */
Waits for the futures to complete.
@param timeout the timeout expressed in TimeUnit units
@param timeUnit TimeUnit
@throws TimeoutException if the waiting time exceeds timeout
Waits for the futures to complete . @param timeout the timeout expressed in TimeUnit units @param timeUnit TimeUnit @throws TimeoutException if the waiting time exceeds timeout
public static void waitOnFutures(List<CreationTimeAwareFuture<?>> hintFutures, long timeout, TimeUnit timeUnit) throws TimeoutException
    {
        for (Future<?> future : hintFutures)
        {
            try
            {
                future.get(timeout, timeUnit);
            }
            catch (InterruptedException ex)
            {
                throw new AssertionError(ex);
            }
            catch (ExecutionException e)
            {
                throw new RuntimeException(e);
            }
        }
    }
public static void waitOnFutures ( List < CreationTimeAwareFuture < ? > > hintFutures , long timeout , TimeUnit timeUnit ) throws TimeoutException { for ( Future < ? > future : hintFutures ) { try { future . get ( timeout , timeUnit ) ; } catch ( InterruptedException ex ) { throw new AssertionError ( ex ) ; } catch ( ExecutionException e ) { throw new RuntimeException ( e ) ; } } }
Waits for the futures to complete.
Waits for the futures to complete .