package www.it.com.test;

/**
 * @author wangjie
 * @date 2019/11/20 17:10
 * @description
 * @company 石文軟件有限公司
 */
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;

/**
 * @author wangjie
 * @date 2019/11/20 17:09
 * @description
 * @company 石文軟件有限公司
 */
public class BranchThread {
  public static void main(String[] args) {
    //準(zhǔn)備數(shù)據(jù)源
    List<User> userList = getInitUser();
    //定義每個線程處理多少用戶
    Integer count = 2;
    //根據(jù)用戶數(shù)確定需要多少個線程
    List<List<User>> lists = splitList(userList, count);
    //將用戶傳每個線程執(zhí)行
    for (List<User> list:lists) {
      UserThread userThread=new UserThread(list);
      Thread thread=new Thread(userThread);
      //啟動線程
      thread.start();
    }



  }

  /**
   * 初始話數(shù)據(jù)
   * @return
   */
  public static List<User> getInitUser() {
    ArrayList<User> 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;
  }

  /**
   * 計算出需要多少個線程
   * @param list
   * @param pageSize
   * @param <T>
   * @return
   */
  public static <T> List<List<T>> splitList(List<T> list, int pageSize) {
    int listSize = list.size();
    int page = (listSize + (pageSize - 1)) / pageSize;
    List<List<T>> listArray = new ArrayList<List<T>>();
    for (int i = 0; i < page; i++) {
      List<T> subList = new ArrayList<T>();
      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;

/**
 * @author wangjie
 * @date 2019/11/20 17:03
 * @description 給11個人分批發(fā)送短信
 * @company 石文軟件有限公司
 */
public class UserThread implements Runnable{

  private List<User> userList;

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

  public List<User> getUserList() {
    return userList;
  }

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

  @Override
  public void run() {
    userList.forEach(user -> {
      System.out.println("線程"+Thread.currentThread().getId()+user.toString());
    });
    
    //調(diào)用第三方發(fā)送短信的接口
  }
}