xin.altitude.common.service.impl

Class ServiceQueueImpl<M extends com.baomidou.mybatisplus.core.mapper.BaseMapper<T>,T extends com.baomidou.mybatisplus.extension.activerecord.Model<T>>

java.lang.Object

com.baomidou.mybatisplus.extension.service.impl.ServiceImpl<M,T>

xin.altitude.common.service.impl.ServiceQueueImpl<M,T>

All Implemented Interfaces:

com.baomidou.mybatisplus.extension.service.IService<T>

public class ServiceQueueImpl<M extends com.baomidou.mybatisplus.core.mapper.BaseMapper<T>,T extends com.baomidou.mybatisplus.extension.activerecord.Model<T>>
extends com.baomidou.mybatisplus.extension.service.impl.ServiceImpl<M,T>

将主键查询合并请求DB

Since:

2021/11/29 17:57

Author:

explore

Field Summary

Fields

Modifier and Type	Field and Description
protected LinkedBlockingQueue<ModelRequest<T>>	queue

Fields inherited from class com.baomidou.mybatisplus.extension.service.impl.ServiceImpl

baseMapper, entityClass, log, mapperClass

Fields inherited from interface com.baomidou.mybatisplus.extension.service.IService

DEFAULT_BATCH_SIZE

Constructor Summary

Constructors

Constructor and Description
ServiceQueueImpl()

Method Summary

Modifier and Type	Method and Description
void	init() 集成子类初始化，每200毫秒发车一次，每次最多100个请求

Methods inherited from class com.baomidou.mybatisplus.extension.service.impl.ServiceImpl

closeSqlSession, currentMapperClass, currentModelClass, executeBatch, executeBatch, executeBatch, getBaseMapper, getEntityClass, getMap, getObj, getOne, getSqlStatement, retBool, saveBatch, saveOrUpdate, saveOrUpdateBatch, sqlSessionBatch, sqlStatement, updateBatchById

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.baomidou.mybatisplus.extension.service.IService

count, count, getById, getOne, ktQuery, ktUpdate, lambdaQuery, lambdaUpdate, list, list, listByIds, listByMap, listMaps, listMaps, listObjs, listObjs, listObjs, listObjs, page, page, pageMaps, pageMaps, query, remove, removeById, removeById, removeByIds, removeByMap, save, saveBatch, saveOrUpdate, saveOrUpdateBatch, update, update, update, updateBatchById, updateById

Field Detail

queue

protected LinkedBlockingQueue<ModelRequest<T extends com.baomidou.mybatisplus.extension.activerecord.Model<T>>> queue

Constructor Detail

ServiceQueueImpl

public ServiceQueueImpl()

Method Detail

init

@PostConstruct
public void init()

集成子类初始化，每200毫秒发车一次，每次最多100个请求