Giriş
Şu satırı dahil ederiz
import com.hazelcast.map.impl.proxy.MapProxySupport;
constructor
Kod şöyle
protected MapProxySupport(String name, MapService service, NodeEngine nodeEngine, MapConfig mapConfig) { super(nodeEngine, service); this.name = name; HazelcastProperties properties = nodeEngine.getProperties(); this.mapServiceContext = service.getMapServiceContext(); this.mapConfig = mapConfig; this.partitionStrategy = mapServiceContext.getPartitioningStrategy(mapConfig.getName(), mapConfig.getPartitioningStrategyConfig(), mapConfig.getPartitioningAttributeConfigs()); this.localMapStats = mapServiceContext.getLocalMapStatsProvider() .getLocalMapStatsImpl(name); this.partitionService = getNodeEngine().getPartitionService(); this.lockSupport = new LockProxySupport(MapService.getObjectNamespace(name), LockSupportServiceImpl.getMaxLeaseTimeInMillis(properties)); this.operationProvider = mapServiceContext.getMapOperationProvider(name); this.operationService = nodeEngine.getOperationService(); this.serializationService = nodeEngine.getSerializationService(); this.thisAddress = nodeEngine.getClusterService().getThisAddress(); this.statisticsEnabled = mapConfig.isStatisticsEnabled(); this.putAllBatchSize = properties.getInteger(MAP_PUT_ALL_BATCH_SIZE); this.putAllInitialSizeFactor = properties.getFloat(MAP_PUT_ALL_INITIAL_SIZE_FACTOR); default value the same as in OperationService this.failOnIndeterminateOperationState = properties .getBoolean(FAIL_ON_INDETERMINATE_OPERATION_STATE); }
İçinde bir çeşit operationProvider isminde MapOperationProvider nesnesi barındırır. Bu MapOperationProvider şeklen şöyle kullanılır. Yani MapProxyImpl ne iş yapacaksa MapOperationProvider sınıfından bir operation nesnesi alır ve onu çalıştırır
Hiç yorum yok:
Yorum Gönder