class MyThread extends Thread {
    @Override
    public void run() {
        // 線程執(zhí)行邏輯
        System.out.println("繼承Thread類的線程: " + Thread.currentThread().getName());
    }
}
public class ThreadDemo {
    public static void main(String[] args) {
        MyThread thread = new MyThread();
        thread.start(); // 啟動(dòng)線程
    }
}

public class RunnableDemo {
    public static void main(String[] args) {
        // 方式1：匿名內(nèi)部類
        new Thread(new Runnable() {
            @Override
            public void run() {
                System.out.println("Runnable匿名內(nèi)部類線程: " + Thread.currentThread().getName());
            }
        }).start();
        // 方式2：Lambda表達(dá)式（推薦）
        new Thread(() -> {
            System.out.println("Runnable Lambda線程: " + Thread.currentThread().getName());
        }).start();
        // 方式3：實(shí)現(xiàn)類
        Runnable task = new MyRunnable();
        new Thread(task).start();
    }
}
class MyRunnable implements Runnable {
    @Override
    public void run() {
        System.out.println("實(shí)現(xiàn)Runnable接口的線程: " + Thread.currentThread().getName());
    }
}

import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.FutureTask;
public class CallableDemo {
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        // 創(chuàng)建Callable任務(wù)
        Callable<String> callableTask = () -> {
            Thread.sleep(1000);
            return "Callable線程執(zhí)行結(jié)果: " + Thread.currentThread().getName();
        };
        // 包裝為FutureTask
        FutureTask<String> futureTask = new FutureTask<>(callableTask);
        // 啟動(dòng)線程
        new Thread(futureTask).start();
        // 獲取結(jié)果（會(huì)阻塞直到任務(wù)完成）
        String result = futureTask.get();
        System.out.println(result);
    }
}

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
public class ThreadPoolDemo {
    public static void main(String[] args) throws Exception {
        // 創(chuàng)建固定大小線程池
        ExecutorService executor = Executors.newFixedThreadPool(3);
        // 提交Runnable任務(wù)
        executor.execute(() -> {
            System.out.println("線程池執(zhí)行Runnable任務(wù): " + Thread.currentThread().getName());
        });
        // 提交Callable任務(wù)
        Future<String> future = executor.submit(() -> {
            Thread.sleep(500);
            return "線程池執(zhí)行Callable任務(wù)結(jié)果: " + Thread.currentThread().getName();
        });
        // 獲取Callable結(jié)果
        System.out.println(future.get());
        // 關(guān)閉線程池
        executor.shutdown();
    }
}

import java.util.concurrent.*;
public class CustomThreadPool {
    public static void main(String[] args) {
        // 創(chuàng)建自定義線程池
        ExecutorService customPool = new ThreadPoolExecutor(
            4, // 核心線程數(shù)
            10, // 最大線程數(shù)
            60, // 空閑線程存活時(shí)間
            TimeUnit.SECONDS, // 時(shí)間單位
            new ArrayBlockingQueue<>(100), // 任務(wù)隊(duì)列
            Executors.defaultThreadFactory(), // 線程工廠
            new ThreadPoolExecutor.CallerRunsPolicy() // 拒絕策略
        );
        // 提交任務(wù)
        for (int i = 0; i < 20; i++) {
            int taskId = i;
            customPool.execute(() -> {
                System.out.println("執(zhí)行任務(wù) " + taskId + " 線程: " + Thread.currentThread().getName());
                try {
                    Thread.sleep(500);
                } catch (InterruptedException e) {
                    Thread.currentThread().interrupt();
                }
            });
        }
        // 優(yōu)雅關(guān)閉
        customPool.shutdown();
        try {
            if (!customPool.awaitTermination(60, TimeUnit.SECONDS)) {
                customPool.shutdownNow();
            }
        } catch (InterruptedException e) {
            customPool.shutdownNow();
            Thread.currentThread().interrupt();
        }
    }
}