public abstract class AbstractAsyncWriteService extends java.lang.Object implements AsyncWriteService
| 限定符和类型 | 字段和说明 |
|---|---|
protected int |
batchOperateNum
批量存档数量
|
protected DataAccessor |
dataAccessor |
protected int |
saveInterval
定时存档间隔,单位:秒
|
protected java.util.concurrent.ScheduledExecutorService |
scheduledExecutorService
这个定时任务,有空就处理一下数据保存和缓存清理功能
|
| 构造器和说明 |
|---|
AbstractAsyncWriteService() |
| 限定符和类型 | 方法和说明 |
|---|---|
protected abstract <T> java.io.Serializable |
analysisGroupIdByEntity(EntityMapping<T> em,
T entity)
智能分析这个实体类的角色Id是多少.
|
void |
asyncFlushByGroupId(java.io.Serializable groupId) |
<T> void |
delete(EntityMapping<T> em,
T entity)
删除一个实体对象.
|
<T> void |
deleteAll(EntityMapping<T> em,
java.util.List<T> result)
删除一批实体对象.
|
void |
init()
初始化存储系统
|
<T> void |
insert(EntityMapping<T> em,
T entity)
插入一个实体对象.
|
protected <T> void |
operation(EntityMapping<T> em,
T entity,
OperateType type)
实体类对象的操作.
|
void |
shutdown()
停机存档,停机前应该保证所有数据都存档完成.
|
void |
syncFlushAll() |
<T> void |
update(EntityMapping<T> em,
T entity)
更新一个实体对象.
|
@Autowired protected DataAccessor dataAccessor
@Value(value="data.save.interval") protected int saveInterval
@Value(value="data.batch.num") protected int batchOperateNum
protected java.util.concurrent.ScheduledExecutorService scheduledExecutorService
public void init()
AsyncWriteServiceinit 在接口中 AsyncWriteServicepublic <T> void insert(EntityMapping<T> em, T entity)
AsyncWriteServiceinsert 在接口中 AsyncWriteServiceT - 实体对象类型em - 实体映射对象entity - 实体对象public <T> void delete(EntityMapping<T> em, T entity)
AsyncWriteServicedelete 在接口中 AsyncWriteServiceT - 实体对象类型em - 实体映射对象entity - 实体对象public <T> void deleteAll(EntityMapping<T> em, java.util.List<T> result)
AsyncWriteServicedeleteAll 在接口中 AsyncWriteServiceT - 实体对象类型em - 实体映射对象result - 实体对象列表public <T> void update(EntityMapping<T> em, T entity)
AsyncWriteServiceupdate 在接口中 AsyncWriteServiceT - 实体对象类型em - 实体映射对象entity - 实体对象protected <T> void operation(EntityMapping<T> em, T entity, OperateType type)
T - 实体类em - 实体对象描述类entity - 实体类对象type - 操作类型protected abstract <T> java.io.Serializable analysisGroupIdByEntity(EntityMapping<T> em, T entity)
T - 实体类型em - 实体类的描述对象.entity - 实体对象.public void shutdown()
AsyncWriteServiceshutdown 在接口中 AsyncWriteServicepublic void syncFlushAll()
public void asyncFlushByGroupId(java.io.Serializable groupId)