Chinaunix首页 | 论坛 | 博客
  • 博客访问: 501918
  • 博文数量: 704
  • 博客积分: 39800
  • 博客等级: 大将
  • 技术积分: 4950
  • 用 户 组: 普通用户
  • 注册时间: 2008-10-15 13:32
文章分类

全部博文(704)

文章存档

2011年(1)

2008年(703)

我的朋友

分类:

2008-10-15 13:43:39

    新的线程加入后,如果正在运行的线程达到了上限,则会阻塞,直到有了空闲的线程来运行。

    import java.util.Random;

    import java.util.concurrent.ExecutorService;

    import java.util.concurrent.Executors;

    import java.util.concurrent.TimeUnit;

    /** * 线程池newFixedThreadPool的使用。

    * * @author 赵学庆,世纪网(java2000.net)

    * */

    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);

    }
   
    }

【责编:huangchunmei】

--------------------next---------------------

阅读(585) | 评论(0) | 转发(0) |
给主人留下些什么吧!~~