Toggle navigation
Home
cloud.orbit.concurrent.ConcurrentHashSet to java.util.Set
No. of Instances - 1
No. of Commits - 1
No. of Projects - {'orbit'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Jdk
Mapping:
Add or Remove Method invocation
concurrentExecutionQueue.execute(() -> actorEntry.deactivate().failAfter(deactivationTimeoutMillis,TimeUnit.MILLISECONDS).whenComplete((r,e) -> { if (e != null) { if (logger.isErrorEnabled()) { logger.error("Error during the deactivation of " + actorEntry.getRemoteReference(),e); } actorEntry.setDeactivated(true); } pendingDeactivations.remove(actorEntry); localObjects.remove(entryEntry.getKey(),entryEntry.getValue()); if (entryEntry.getKey() == actorEntry.getRemoteReference()) { hosting.actorDeactivated(actorEntry.getRemoteReference()); } } ))
to
concurrentExecutionQueue.execute(() -> actorEntry.deactivate().failAfter(deactivationTimeoutMillis,TimeUnit.MILLISECONDS).whenComplete((r,e) -> { if (e != null) { if (logger.isErrorEnabled()) { logger.error("Error during the deactivation of " + actorEntry.getRemoteReference(),e); } actorEntry.setDeactivated(true); } try { localObjects.remove(entryEntry.getKey(),entryEntry.getValue()); if (entryEntry.getKey() == actorEntry.getRemoteReference()) { hosting.actorDeactivated(actorEntry.getRemoteReference()); } } finally { pendingDeactivations.remove(actorEntry); } } ))