package com.qianfeng.day22_Thread.Excutors;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class TestExecutors {
public static void main(String[] args) {
// 创建2个线程池对象
ExecutorService service = Executors.newFixedThreadPool(2);
for (int i = 0; i < 10; i++) {
service.execute(new Runnable() { // 执行任务
@Override
public void run() {
for (int i = 0; i < 100; i++) {
System.out.println(Thread.currentThread().getName() + ":" + i);
}
}
});
}
// 一般情况下,如果程序退出了,需要销毁线程
service.shutdown();
service = null;
}
}
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class TestExecutors {
public static void main(String[] args) {
// 创建2个线程池对象
ExecutorService service = Executors.newFixedThreadPool(2);
for (int i = 0; i < 10; i++) {
service.execute(new Runnable() { // 执行任务
@Override
public void run() {
for (int i = 0; i < 100; i++) {
System.out.println(Thread.currentThread().getName() + ":" + i);
}
}
});
}
// 一般情况下,如果程序退出了,需要销毁线程
service.shutdown();
service = null;
}
}