java 并发查询_java并发查询数据

并发服务

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

并发服务 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