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 Active<future, String> get(){
- return Futures.allTypeclasses(Future.ofSupplier(ex, () -> "load data asynchronously"));
- }
- @Override
- public Active<future, Boolean> save(String data){
- return Futures.allTypeclasses(Future.ofSupplier(ex,()->true));
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement