java并发查询数据

Posted 2021-03-22 tiana_Z

　　并发服务

　　package com.springboot_android.thread;

　　import com.project_entity.bean.DeviceRecrodBean;

　　import com.springboot_android.dao.DeviceRecrodDao;

　　import java.util.*;

　　import java.util.concurrent.Callable;

　　/**

　　* 历史数据，多线程处理

　　*/

　　public class ThreadCall implements Callable>{

　　private String identifier;

　　private String deviceName;

　　private String productKey;

　　private Date startTime;

　　private Date endTime;

　　private DeviceRecrodDao deviceRecrodDao;

　　private int groupId;

　　public ThreadCall(String identifier,String deviceName,String productKey,Date startTime,Date endTime,DeviceRecrodDao deviceRecrodDao,int groupId){

　　this.identifier=identifier;

　　this.deviceName=deviceName;

　　this.productKey=productKey;

　　this.startTime=startTime;

　　this.endTime=endTime;

　　this.deviceRecrodDao=deviceRecrodDao;

　　this.groupId=groupId;

　　}

　　@Override

　　public Map call() throws Exception {

　　//开始执行并发任务

　　Map map=new HashMap<>();

　　/*List list = deviceRecrodDao.selectDeviceProductKeyId( productKey, deviceName, identifier,startTime, endTime);

　　map.put("value",list);郑州人流专科医院 http://www.03912316666.com/

　　map.put("identifier",identifier);

　　map.put("productKey",productKey);

　　map.put("deviceName",deviceName);

　　map.put("groupId",groupId);*/

　　return map;

　　}

　　}

　　并发服务调用：

　　package com.springboot_android.thread;

　　import com.project_entity.bean.mobe.DeviceGroupGraphBean;

　　import com.springboot_android.dao.DeviceRecrodDao;

　　import org.springframework.beans.factory.annotation.Autowired;

　　import org.springframework.stereotype.Component;

　　import java.util.*;

　　import java.util.concurrent.*;

　　@Component

　　public class InfoMore {

　　@Autowired

　　private DeviceRecrodDao recrodDao;

　　//根据集合中的内容查询所有数据

　　public List