新的线程加入后,如果正在运行的线程达到了上限,则会阻塞,直到有了空闲的线程来运行。
  1. import java.util.Random;
  2. import java.util.concurrent.ExecutorService;
  3. import java.util.concurrent.Executors;
  4. import java.util.concurrent.TimeUnit;
  5. /**
  6.  * 线程池newFixedThreadPool的使用。
  7.  * 
  8.  * @author 赵学庆,Java世纪网(java2000.net)
  9.  * 
  10.  */
  11. public class ExecutorTest {
  12.   public static void main(String args[]) {
  13.     Random random = new Random();
  14.     // 建立一个容量为3的固定尺寸的线程池
  15.     ExecutorService executor = Executors.newFixedThreadPool(3);
  16.     // 判断可是线程池可以结束
  17.     int waitTime = 500;
  18.     for (int i = 0; i < 10; i++) {
  19.       String name = "线程 " + i;
  20.       int time = random.nextInt(1000);
  21.       waitTime += time;
  22.       Runnable runner = new ExecutorThread(name, time);
  23.       System.out.println("增加: " + name + " / " + time);
  24.       executor.execute(runner);
  25.     }
  26.     try {
  27.       Thread.sleep(waitTime);
  28.       executor.shutdown();
  29.       executor.awaitTermination(waitTime, TimeUnit.MILLISECONDS);
  30.     } catch (InterruptedException ignored) {
  31.     }
  32.   }
  33. }
  34. class ExecutorThread implements Runnable {
  35.   private final String name;
  36.   private final int delay;
  37.   public ExecutorThread(String name, int delay) {
  38.     this.name = name;
  39.     this.delay = delay;
  40.   }
  41.   public void run() {
  42.     System.out.println("启动: " + name);
  43.     try {
  44.       Thread.sleep(delay);
  45.     } catch (InterruptedException ignored) {
  46.     }
  47.     System.out.println("完成: " + name);
  48.   }
  49. }
GitHub 加速计划 / th / ThreadPool
7.74 K
2.22 K
下载
A simple C++11 Thread Pool implementation
最近提交(Master分支:2 个月前 )
9a42ec13 - 9 年前
fcc91415 - 9 年前
Logo

旨在为数千万中国开发者提供一个无缝且高效的云端环境,以支持学习、使用和贡献开源项目。

更多推荐