Toggle navigation
Home
java.util.concurrent.Future to com.google.common.util.concurrent.ListenableFuture
No. of Instances - 7
No. of Commits - 3
No. of Projects - {'kaa'}
Hierarchy/Composition: T_SUPER_R
Primitive Info: -
NameSpace: Jdk -> External
Mapping:
Cascading Type Change (Different)
CacheLoader<MissingShard,Future<?>>
to
CacheLoader<MissingShard,ListenableFuture<?>>
Add or Remove Method invocation
CacheBuilder.newBuilder().build(new CacheLoader<MissingShard,ListenableFuture<?>>(){ @Override public Future<?> load( MissingShard missingShard){ MissingShardRecovery task=new MissingShardRecovery(missingShard.getShardUuid(),missingShard.getShardSize(),missingShard.isActive()); ListenableFuture<?> future=shardRecoveryExecutor.submit(task); future.addListener(() -> queuedMissingShards.invalidate(missingShard),directExecutor()); return future; } } )
to
CacheBuilder.newBuilder().build(new CacheLoader<MissingShard,ListenableFuture<?>>(){ @Override public ListenableFuture<?> load( MissingShard missingShard){ MissingShardRecovery task=new MissingShardRecovery(missingShard.getShardUuid(),missingShard.getShardSize(),missingShard.isActive()); ListenableFuture<?> future=shardRecoveryExecutor.submit(task); future.addListener(() -> queuedMissingShards.invalidate(missingShard),directExecutor()); return future; } } )