public abstract class AbstractTransactionExecutor extends Object implements TransactionExecutor
TransactionExecutor
by delegating their execution
to respective synchronous methods via provided ExecutorService
.TransactionExecutor.Function<I,O>, TransactionExecutor.Procedure<I>, TransactionExecutor.Subroutine
Modifier | Constructor and Description |
---|---|
protected |
AbstractTransactionExecutor(ExecutorService executorService) |
Modifier and Type | Method and Description |
---|---|
<O> O |
executeUnchecked(Callable<O> callable)
Same as
TransactionExecutor.execute(Callable) but
suppresses exception with Throwables.propagate(Throwable) |
<I,O> O |
executeUnchecked(TransactionExecutor.Function<I,O> function,
I input)
Same as
TransactionExecutor.execute(Function, Object) but
suppresses exception with Throwables.propagate(Throwable) |
<I> void |
executeUnchecked(TransactionExecutor.Procedure<I> procedure,
I input)
Same as
TransactionExecutor.execute(Procedure, Object) but
suppresses exception with Throwables.propagate(Throwable) |
void |
executeUnchecked(TransactionExecutor.Subroutine subroutine)
Same as
TransactionExecutor.execute(Subroutine) but
suppresses exception with Throwables.propagate(Throwable) |
<O> com.google.common.util.concurrent.ListenableFuture<O> |
submit(Callable<O> callable)
Same as
TransactionExecutor.execute(Callable) but executes asynchronously |
<I,O> com.google.common.util.concurrent.ListenableFuture<O> |
submit(TransactionExecutor.Function<I,O> function,
I input)
Same as
TransactionExecutor.execute(Function, Object) but executes asynchronously |
<I> com.google.common.util.concurrent.ListenableFuture<?> |
submit(TransactionExecutor.Procedure<I> procedure,
I input)
Same as
TransactionExecutor.execute(Procedure, Object) but executes asynchronously |
com.google.common.util.concurrent.ListenableFuture<?> |
submit(TransactionExecutor.Subroutine subroutine)
Same as
TransactionExecutor.execute(Subroutine) but executes asynchronously |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
execute, execute, execute, execute
protected AbstractTransactionExecutor(ExecutorService executorService)
public <I,O> O executeUnchecked(TransactionExecutor.Function<I,O> function, I input)
TransactionExecutor
TransactionExecutor.execute(Function, Object)
but
suppresses exception with Throwables.propagate(Throwable)
executeUnchecked
in interface TransactionExecutor
public <I> void executeUnchecked(TransactionExecutor.Procedure<I> procedure, I input)
TransactionExecutor
TransactionExecutor.execute(Procedure, Object)
but
suppresses exception with Throwables.propagate(Throwable)
executeUnchecked
in interface TransactionExecutor
public <O> O executeUnchecked(Callable<O> callable)
TransactionExecutor
TransactionExecutor.execute(Callable)
but
suppresses exception with Throwables.propagate(Throwable)
executeUnchecked
in interface TransactionExecutor
public void executeUnchecked(TransactionExecutor.Subroutine subroutine)
TransactionExecutor
TransactionExecutor.execute(Subroutine)
but
suppresses exception with Throwables.propagate(Throwable)
executeUnchecked
in interface TransactionExecutor
public <I,O> com.google.common.util.concurrent.ListenableFuture<O> submit(TransactionExecutor.Function<I,O> function, I input)
TransactionExecutor
TransactionExecutor.execute(Function, Object)
but executes asynchronouslysubmit
in interface TransactionExecutor
public <I> com.google.common.util.concurrent.ListenableFuture<?> submit(TransactionExecutor.Procedure<I> procedure, I input)
TransactionExecutor
TransactionExecutor.execute(Procedure, Object)
but executes asynchronouslysubmit
in interface TransactionExecutor
public <O> com.google.common.util.concurrent.ListenableFuture<O> submit(Callable<O> callable)
TransactionExecutor
TransactionExecutor.execute(Callable)
but executes asynchronouslysubmit
in interface TransactionExecutor
public com.google.common.util.concurrent.ListenableFuture<?> submit(TransactionExecutor.Subroutine subroutine)
TransactionExecutor
TransactionExecutor.execute(Subroutine)
but executes asynchronouslysubmit
in interface TransactionExecutor
Copyright © 2016 The Apache Software Foundation. All rights reserved.