代码:

/**

 *

 * @classDesc: 功能描述:(创建多线程例子-Thread类 重写run方法)

 * @author: 余胜军

 * @version: v1.0

 * @copyright:上海每特教育科技有限公司

 */

class CreateThread extends Thread {

    // run方法中编写 多线程需要执行的代码

    publicvoid run() {

         for (inti = 0; i< 10; i++) {

             System.out.println("i:" + i);

         }

    }

}

publicclass ThreadDemo {

    publicstaticvoid main(String[] args) {

         System.out.println("-----多线程创建开始-----");

         // 1.创建一个线程

         CreateThread createThread = new CreateThread();

         // 2.开始执行线程 注意 开启线程不是调用run方法，而是start方法

         System.out.println("-----多线程创建启动-----");

         createThread.start();

         System.out.println("-----多线程创建结束-----");

    }

}

/**

 *

 * @classDesc: 功能描述:(创建多线程例子-Thread类 重写run方法)

 * @author: 余胜军

 * @version: v1.0

 * @copyright:上海每特教育科技有限公司

 */

class CreateRunnable implements Runnable {

    @Override

    publicvoid run() {

         for (inti = 0; i< 10; i++) {

             System.out.println("i:" + i);

         }

    }

}

/**

 *

 * @classDesc: 功能描述:(实现Runnable接口,重写run方法)

 * @author: 余胜军

 * @version: v1.0

 * @copyright:上海每特教育科技有限公司

 */

publicclass ThreadDemo2 {

    publicstaticvoid main(String[] args) {

         System.out.println("-----多线程创建开始-----");

         // 1.创建一个线程

         CreateRunnable createThread = new CreateRunnable();

         // 2.开始执行线程 注意 开启线程不是调用run方法，而是start方法

         System.out.println("-----多线程创建启动-----");

         Thread thread = new Thread(createThread);

         thread.start();

         System.out.println("-----多线程创建结束-----");

    }

}

 System.out.println("-----多线程创建开始-----");

          Thread thread = new Thread(new Runnable() {

             public void run() {

                  for (int i = 0; i< 10; i++) {

                      System.out.println("i:" + i);

                  }

             }

         });

          thread.start();

          System.out.println("-----多线程创建结束-----");

常用线程api方法

start()

启动线程

currentThread()

获取当前线程对象

getID()

获取当前线程ID      Thread-编号  该编号从0开始

getName()

获取当前线程名称

sleep(long mill)

休眠线程

Stop（）

停止线程

常用线程构造函数

Thread（）

分配一个新的 Thread 对象

Thread（String name）

分配一个新的 Thread对象，具有指定的 name正如其名。

Thread（Runable r）

分配一个新的 Thread对象

Thread（Runable r, String name）

分配一个新的 Thread对象

package com.itmayiedu.enity;

/**

 *

 * @classDesc: 功能描述:(用户实体类)

 * @author: 余胜军

 * @createTime: 2017年8月7日 下午9:01:20

 * @version: v1.0

 * @copyright:上海每特教育科技有限公司

 */

publicclass UserEntity {

private String userId;

private String userName;

public String getUserId() {

returnuserId;

}

publicvoid setUserId(String userId) {

this.userId = userId;

}

public String getUserName() {

return userName;

}

publicvoid setUserName(String userName) {

this.userName = userName;

}

}

Class UserThreadextends Thread {

    private List<UserEntity>list;

/**

     * 通过构造函数 传入每个线程需要执行的发送短信内容

     *

     * @param list

     */

    public UserThread(List<UserEntity>list) {

         this.list = list;

    }

/**

     *

     * @methodDesc: 功能描述:(分批发送短信)

     * @author: 余胜军

     * @param:

     * @createTime:2017年8月7日 下午9:09:54

     * @returnType: void

     * @copyright:上海每特教育科技有限公司

     */

    publicvoid run() {

         for (UserEntity userEntity : list) {

             System.out.println("threadName:" + Thread.currentThread().getName() + "-学员编号:" + userEntity.getUserId()

                      + "---学员名称:" + userEntity.getUserName());

             // 调用发送短信具体代码

         }

    }

}

/**

    *

    * @methodDesc: 功能描述:(初始化数据)

    * @author: 余胜军

    * @param:

    * @createTime:2017年8月7日 下午9:16:53

    * @returnType: void

    * @copyright:上海每特教育科技有限公司

    */

   publicstatic List<UserEntity> init() {

      List<UserEntity>list = new ArrayList<UserEntity>();

      for (inti = 1; i<= 140; i++) {

          UserEntity userEntity = new UserEntity();

          userEntity.setUserId("userId" + i);

          userEntity.setUserName("userName" + i);

          list.add(userEntity);

      }

      returnlist;

   }

/**

*

* @classDesc: 功能描述:(Java集合工具类)

* @author: 余胜军

* @createTime: 2017年8月7日 下午9:30:48

* @version: v1.0

* @copyright:上海每特教育科技有限公司

*/

Public class ListUtils {

/**

*

* @methodDesc: 功能描述:(list 集合分批切割)

* @author: 余胜军

* @param: @param

*             list

* @param: @param

*             pageSize

* @param: @return

* @createTime:2017年8月7日 下午9:30:59

* @returnType:@param list   切割集合

* @returnType:@param pageSize  分页长度

* @returnType:@return List<List<T>> 返回分页数据

* @copyright:上海每特教育科技有限公司

*/

Static public<T> List<List<T>> splitList(List<T>list, intpageSize) {

intlistSize = list.size();

intpage = (listSize + (pageSize - 1)) / pageSize;

List<List<T>>listArray = new ArrayList<List<T>>();

for (inti = 0; i<page; i++) {

List<T>subList = new ArrayList<T>();

for (intj = 0; j<listSize; j++) {

intpageIndex = ((j + 1) + (pageSize - 1)) / pageSize;

if (pageIndex == (i + 1)) {

subList.add(list.get(j));

}

if ((j + 1) == ((j + 1) * pageSize)) {

break;

}

}

listArray.add(subList);

}

returnlistArray;

}

}

Public staticvoid main(String[] args) {

      // 1.初始化用户数据

      List<UserEntity>listUserEntity = init();

      // 2.计算创建创建多少个线程并且每一个线程需要执行“分批发送短信用户”

      // 每一个线程分批跑多少

      intuserThreadPage = 50;

      // 计算所有线程数

      List<List<UserEntity>>splitUserList = ListUtils.splitList(listUserEntity, userThreadPage);

      intthreadSaze = splitUserList.size();

      for (inti = 0; i<threadSaze; i++) {

          List<UserEntity>list = splitUserList.get(i);

          UserThread userThread = new UserThread(list);

          // 3.执行任务发送短信

          userThread.start();

      }

   }