package com.yicurtain.THREAD;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
class Numbers implements Runnable{
@Override
public void run() {
for (int i = 0; i < 100; i++) {
if(i%2==0){
System.out.println(Thread.currentThread().getName()+":"+i);
}
}
}
}
class Numbers1 implements Runnable{
@Override
public void run() {
for (int i = 0; i < 100; i++) {
if(i%2!=0){
System.out.println(Thread.currentThread().getName()+":"+i);
}
}
}
}
public class ThreadPool {
public static void main(String[] args) {
// 1.提供指定线程数量的线程池
ExecutorService Service = Executors.newFixedThreadPool(10);
//2.执行指定的线程的操作。需要提供实现Runnable接口或Callable接口实现类的对象
Service.execute(new Numbers());
Service.execute(new Numbers1());//适合Runnable
//Service.submit() 适合Callable
//3.关闭线程池
Service.shutdown();
}
}
原文:https://www.cnblogs.com/yicurtain/p/14908758.html