HazelcastAPI StoreWorker Sınıfı

Giriş

Şu satırı dahil ederiz

import com.hazelcast.map.impl.mapstore.writebehind.StoreWorker;

Kod şöyle. Yani her bir WriteBehindMap için bir tane StoreWorker var. Bu runnable Partition Thread tarafından çalıştırılıyor. StoreWorker member üzerindeki tüm partition'ları dolaşır ve bir yere yazılmasını sağlar.

/**
 * When write-behind is enabled the work is offloaded to another thread than 
 * partition-operation-thread.
 * That thread uses this runnable task to process write-behind-queues. 
 * This task collects entries from write behind queues and passes them 
 * to {@link #writeBehindProcessor}.
 * <p>
 * Only one {@link StoreWorker} task is created for a map on a member.
 */
public class StoreWorker implements Runnable {

  private final String mapName;
  ...
}