JAVA模拟多线程给多用户发送短信

这篇文章主要介绍了JAVA模拟多线程给多用户发送短信,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下

代码编写逻辑，假设需要给11个用户发送短信，每一个线程给两个用户发送短信，实现多线程的并发处理

创建实体user

package www.it.com.test;


public class User {

  private String name;
  private Integer id;

  public String getName() {
    return name;
  }

  public void setName(String name) {
    this.name = name;
  }

  public Integer getId() {
    return id;
  }

  public void setId(Integer id) {
    this.id = id;
  }

  public User() {
  }

  public User(String name, Integer id) {
    this.name = name;
    this.id = id;
  }

  @Override
  public String toString() {
    return "User{" +
 "name='" + name + ''' +
 ", id=" + id +
 '}';
  }
}

业务代码

package www.it.com.test;

import java.util.ArrayList;
import java.util.List;


public class BranchThread {
  public static void main(String[] args) {
    //准备数据源
    List userList = getInitUser();
    //定义每个线程处理多少用户
    Integer count = 2;
    //根据用户数确定需要多少个线程
    List> lists = splitList(userList, count);
    //将用户传每个线程执行
    for (List list:lists) {
      UserThread userThread=new UserThread(list);
      Thread thread=new Thread(userThread);
      //启动线程
      thread.start();
    }



  }

  
  public static List getInitUser() {
    ArrayList list = new ArrayList<>();
    for (int i = 0; i < 11; i++) {
      User user = new User();
      user.setId(i);
      String name = String.valueOf(i);
      user.setName(name);
      list.add(user);
    }
    return list;
  }

  
  public static  List> splitList(List list, int pageSize) {
    int listSize = list.size();
    int page = (listSize + (pageSize - 1)) / pageSize;
    List> listArray = new ArrayList>();
    for (int i = 0; i < page; i++) {
      List subList = new ArrayList();
      for (int j = 0; j < listSize; j++) {
 int pageIndex = ((j + 1) + (pageSize - 1)) / pageSize;
 if (pageIndex == (i + 1)) {
   subList.add(list.get(j));
 }
 if ((j + 1) == ((j + 1) * pageSize)) {
   break;
 }
      }
      listArray.add(subList);
    }
    return listArray;
  }
}

创建线程

package www.it.com.test;

import java.util.List;


public class UserThread implements Runnable{

  private List userList;

  public UserThread(List userList) {
    this.userList = userList;
  }

  public List getUserList() {
    return userList;
  }

  public void setUserList(List userList) {
    this.userList = userList;
  }

  @Override
  public void run() {
    userList.forEach(user -> {
      System.out.println("线程"+Thread.currentThread().getId()+user.toString());
    });
    
    //调用第三方发送短信的接口
  }
}

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持考高分网。