|
子类实现接口：
public class ThreadPoolRunnable implements Runnable { ?? ?public void run(){
?? ??? ?System.out.println(Thread.currentThread().getName()+"线程提交任务");
?? ?}
}
测试类：
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
/*
?* JDK1.5的新特性，实现线程池程序
?* 使用工厂类Executors中的静态方法创建线程对象，指定线程的个数
?* ?? ?static ExecutorService newFixedThreadPool(int 个数)：返回线程池对象
?* 返回的是ExecutorService接口的实现类(线程池对象)
?*
?* 接口实现类对象，调用方法submit(Runnable r)提交线程执行任务
?*/
public class ThreadPoolDemo {
?? ?public static void main(String[] args) {
?? ??? ?//调用工厂类的静态方法，创建线程池对象
?? ??? ?//返回线程池对象，是返回的接口
?? ??? ?ExecutorService es=Executors.newFixedThreadPool(2);
?? ??? ?//调用接口实现类对象es中的方法submit提交线程任务
?? ??? ?//将Runnable接口实现类对象，传递
?? ??? ?es.submit(new ThreadPoolRunnable());
?? ??? ?es.submit(new ThreadPoolRunnable());
?? ??? ?es.submit(new ThreadPoolRunnable());
?? ??? ?
?? ??? ?//关闭线程池
?? ??? ?//es.shutdown();
?? ?}
}
（编辑：北几岛）
【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!
|
