import com.hazelcast.map.AbstractEntryProcessor; //导入依赖的package包/类
/**
 * Apply an entry processor to an entry.
 *
 * @param <T>
 *          the return type of the processor
 * @param id
 *          the ID of the entry
 * @param applyOnBackup
 *          whether to apply the processor on backup entries
 * @param processor
 *          the processor
 * @return the result
 */
@SuppressWarnings("unchecked")
static <T> T execute(GlobalID id, boolean applyOnBackup,
    EntryProcessor<T> processor) {
  try {
    return (T) GlobalRuntimeImpl.getRuntime().resilientFinishMap.executeOnKey(
        id, new AbstractEntryProcessor<GlobalID, ResilientFinishState>(
            applyOnBackup) {
          private static final long serialVersionUID = -8787905766218374656L;

          @Override
          public T process(Map.Entry<GlobalID, ResilientFinishState> entry) {
            return processor.process(entry);
          }
        });
  } catch (final DeadPlaceError | HazelcastInstanceNotActiveException e) {
    // this place is dead for the world
    System.exit(42);
    throw e;
  }
}
 

import com.hazelcast.map.AbstractEntryProcessor; //导入依赖的package包/类
public static <K, V> EntryProcessor<K, V> entryProcessor(
        DistributedBiFunction<? super K, ? super V, ? extends V> remappingFunction
) {
    return new AbstractEntryProcessor<K, V>() {
        @Override
        public Object process(Entry<K, V> entry) {
            V newValue = remappingFunction.apply(entry.getKey(), entry.getValue());
            entry.setValue(newValue);
            return newValue;
        }
    };
}