//1.自定义一个类继承Thread类public class ExThread extends Thread { //2.重写run() @Override public void run() { for (int i = 0; i < 100; i++) { System.out.println(Thread.currentThread().getName()+”:”+i); } } public static void main(String[] args) { //3.创建Thread子类对象 ExThread exThread = new ExThread(); //4.调用start方法启动自定义线程 exThread.start(); } }
//1.自定义一个类实现Runnable接口public class ImThread implements Runnable{ //2.实现run() @Override public void run() { for (int i = 0; i < 100; i++) { System.out.println(Thread.currentThread().getName()+”:”+i); } } public static void main(String[] args) { //3.创建Runnable实现类对象 ImThread imThread = new ImThread(); //4.创建Thread对象 Thread thread = new Thread(imThread); //5.调用start()开启线程 thread.start(); } }
创建一个固定线程数的线程池，可控制线程最大并发数，超出的线程会在队列中等待
import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; public class CreateThreadByFixedPool { /** * Cover Runnable.run() */ private static void run(){ System.out.println(Thread.currentThread().getName()+" is running..."
