Giriş
Şu satırı dahil ederiz
import com.hazelcast.durableexecutor.DurableExecutorService;
Eğer durability atandıysa, member kapanırsa bile çalışmakta olan edilen iş kaybolmaz. Başka bir member'da tekrar başlatılır
Örnek
Şöyle yaparız
Config config = new Config();
config.getDurableExecutorConfig("MyService").setDurability(2).setCapacity(200).setPoolSize(2);
HazelcastInstance hc = Hazelcast.newHazelcastInstance(config);
hc.getMap("MyMap").put("Key-1", "Value-1");
DurableExecutorService service = hc.getDurableExecutorService("MyService");
service.executeOnKeyOwner(new MyRunnable(), "Key-1"); com.hazelcast.durableexecutor.DurableExecutorService;aa. aa
Hiç yorum yok:
Yorum Gönder