这期内容当中小编将会给大家带来有关JAVA模拟多线程怎么给多用户发送短信,文章内容丰富且以专业的角度为大家分析和叙述,阅读完这篇文章希望大家可以有所收获。
代码编写逻辑,假设需要给11个用户发送短信,每一个线程给两个用户发送短信,实现多线程的并发处理
创建实体user
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) { //准备数据源 List<User> userList = getInitUser(); //定义每个线程处理多少用户 Integer count = 2; //根据用户数确定需要多少个线程 List<List<User>> lists = splitList(userList, count); //将用户传每个线程执行 for (List<User> list:lists) { UserThread userThread=new UserThread(list); Thread thread=new Thread(userThread); //启动线程 thread.start(); } } /** * 初始话数据 * @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个人分批发送短信 * @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()); }); //调用第三方发送短信的接口 }}
上述就是小编为大家分享的JAVA模拟多线程怎么给多用户发送短信了,如果刚好有类似的疑惑,不妨参照上述分析进行理解。如果想知道更多相关知识,欢迎关注亿速云行业资讯频道。
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。