线程池newFixedThreadPool的使用

来源:计算机等级考试    发布时间:2012-08-29    计算机等级考试视频    评论

  Examda提示: 新的线程加入后,如果正在运行的线程达到了上限,则会阻塞,直到有了空闲的线程来运行。
  import java.util.Random;
  import java.util.concurrent.ExecutorService;
  import java.util.concurrent.Executors;
  import java.util.concurrent.TimeUnit;
  /**
  * 线程池newFixedThreadPool的使用。
  *
  *
  *
  */
  public class ExecutorTest {
  public static void main(String args[]) {
  Random random = new Random();
  // 建立一个容量为3的固定尺寸的线程池
  ExecutorService executor = Executors.newFixedThreadPool(3);
  // 判断可是线程池可以结束
  int waitTime = 500;
  for (int i = 0; i < 10; i++) {
  String name = "线程 " + i;
  int time = random.nextInt(1000);
  waitTime += time;
  Runnable runner = new ExecutorThread(name, time);
  System.out.println("增加: " + name + " / " + time);
  executor.execute(runner);
  }
  try {
  Thread.sleep(waitTime);
  executor.shutdown();
  executor.awaitTermination(waitTime, TimeUnit.MILLISECONDS);
  } catch (InterruptedException ignored) {
  }
  }
  }
  class ExecutorThread implements Runnable {
  private final String name;
  private final int delay;
  public ExecutorThread(String name, int delay) {
  this.name = name;
  this.delay = delay;
  }
  public void run() {
  System.out.println("启动: " + name);
  try {
  Thread.sleep(delay);
  } catch (InterruptedException ignored) {
  }
  System.out.println("完成: " + name);
  }
  } 考试大论坛

视频学习

我考网版权与免责声明

① 凡本网注明稿件来源为"原创"的所有文字、图片和音视频稿件,版权均属本网所有。任何媒体、网站或个人转载、链接转贴或以其他方式复制发表时必须注明"稿件来源:我考网",违者本网将依法追究责任;

② 本网部分稿件来源于网络,任何单位或个人认为我考网发布的内容可能涉嫌侵犯其合法权益,应该及时向我考网书面反馈,并提供身份证明、权属证明及详细侵权情况证明,我考网在收到上述法律文件后,将会尽快移除被控侵权内容。

最近更新

社区交流

考试问答