2.1新建线程

2018-06-18 03:26:19来源:未知 阅读 ()

新老客户大回馈,云服务器低至5折

public class 自定义线程创建 {
public static void main(String[] args) {
ThreadPoolExecutor threadPoolExecutor=new ThreadPoolExecutor(2,
5,
0,
TimeUnit.SECONDS,
new ArrayBlockingQueue<Runnable>(2),
new ThreadFactory() {
public Thread newThread(Runnable r) {
Thread t=new Thread(r);
System.out.println("Creat");
return t;
}
},
// new ThreadPoolExecutor.AbortPolicy());//第一种拒绝策略:直接抛出异常AbortPolicy
new ThreadPoolExecutor.CallerRunsPolicy());//第二种拒绝策略:新建一个线程
// new ThreadPoolExecutor.DiscardOldestPolicy());//第三种拒绝策略:在队列里推出一个最早的
// new ThreadPoolExecutor.DiscardPolicy());//第四种:直接丢弃。
// new RejectedExecutionHandler() {
// public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
// System.out.println(Thread.currentThread().getName() + "被抛弃了");
// try {
// Thread.sleep(2000);
// } catch (InterruptedException e) {
// e.printStackTrace();
// }
// System.out.println(Thread.currentThread().getName() + "拒绝成功");
//
// }
// });//第种:直接丢弃。
for (int i = 0; i < 10; i++) {
final int finalI = i;
threadPoolExecutor.execute(new Runnable() {
public void run() {
System.out.println(Thread.currentThread().getName()+"开始"+ finalI);
try {
Thread.sleep(10000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName()+"结束"+ finalI); }
});
}
}
}

标签:

版权申明:本站文章部分自网络,如有侵权,请联系:west999com@outlook.com
特别注意:本站所有转载文章言论不代表本站观点,本站所提供的摄影照片,插画,设计作品,如需使用,请与原作者联系,版权归原作者所有

上一篇:Junit 测试 @Test 红名问题

下一篇:Java线程中的同步