org.corfudb.runtime.view

Class QuorumFuturesFactory

java.lang.Object

org.corfudb.runtime.view.QuorumFuturesFactory

public class QuorumFuturesFactory
extends Object

Factory for custom futures used by the quorum replication. Created by Konstantin Spirov on 2/3/2017.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	QuorumFuturesFactory.CompositeFuture<R>

Constructor Summary

Constructors

Constructor and Description
QuorumFuturesFactory()

Method Summary

Modifier and Type	Method and Description
static <R> QuorumFuturesFactory.CompositeFuture<R>	getQuorumFuture(Comparator<R> comparator, CompletableFuture<R>[] futures, Class... failFastThrowables) Get a thread safe future that will complete only when n/2+1 futures complete or if there is no hope (if n/2+1 futures are canceled or have conflicting value).

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

QuorumFuturesFactory

public QuorumFuturesFactory()

Method Detail

getQuorumFuture

public static <R> QuorumFuturesFactory.CompositeFuture<R> getQuorumFuture(Comparator<R> comparator,
                                                                          CompletableFuture<R>[] futures,
                                                                          Class... failFastThrowables)

Get a thread safe future that will complete only when n/2+1 futures complete or if there is no hope (if n/2+1 futures are canceled or have conflicting value).

The future returned does not block explicitly, it aggregates the futures and delegates the blocking.

In case of normal execution, any of the compete futures can be used to return the result. In case of termination, the cancel flag will be updated and if any of the futures threw an exception, ExecutionException will be thrown, otherwise the future will return null.

Parameters:

comparator - Any comparator consistent with equals that is able to distinguish the results

futures - The N futures

failFastThrowables - list of exceptions that will cause the future to complete immediately. All fail fast exceptions are directly propagated and thrown outside.

Returns:

The composite future