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

原文地址:https://www.cnblogs.com/djw12333/p/12059610.html