Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- public class AsyncWork implements GenericWork<future>{
- private ExecutorService ex = Executors.newFixedThreadPool(2);
- @Override
- public FutureKind<String> get(){
- return FutureKind.widen(Future.ofSupplier(ex, () -> "load data asynchronously"));
- }
- @Override
- public FutureKind<Boolean> save(String data){
- return FutureKind.widen((Future.ofSupplier(ex,()->true)));
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement