一、Java多线程基础
在Java中,线程是执行并发操作的基本单位。多线程是指一个应用程序中有多个执行线程同时运行,协同完成不同的任务。Java多线程的实现主要通过继承java.lang.Thread
类或实现java.lang.Runnable
接口来完成。
继承Thread类创建线程
- class MyThread extends Thread {
- public void run() {
- // 线程执行的代码
- }
- }
- MyThread myThread = new MyThread();
- myThread.start(); // 启动线程
2.实现Runnable接口创建线程
- class MyRunnable implements Runnable {
- public void run() {
- // 线程执行的代码
- }
- }
- MyRunnable myRunnable = new MyRunnable();
- Thread thread = new Thread(myRunnable);
- thread.start(); // 启动线程
二、Java线程池
虽然多线程可以提高程序的并发性能,但频繁地创建和销毁线程会带来一定的性能开销。线程池是一种优化技术,通过预先创建一定数量的线程,并将这些线程放在池中等待任务,从而避免了频繁地创建和销毁线程。
Java中的线程池可以通过java.util.concurrent.Executors
类来创建。该类提供了多种创建线程池的工厂方法,例如:newFixedThreadPool
、newSingleThreadExecutor
等。下面是一个使用newFixedThreadPool
创建固定大小线程池的示例:
- ExecutorService executorService = Executors.newFixedThreadPool(10); // 创建10个线程的线程池
- executorService.execute(new MyRunnable()); // 提交任务到线程池中执行
- executorService.shutdown(); // 关闭线程池(非阻塞)
可以通过java.util.concurrent.ThreadPoolExecutor
类来配置线程池的参数,例如:核心线程数、最大线程数、空闲时间、工作队列等。此外,还可以通过添加钩子来监控线程池的运行状态,以便及时发现问题并进行调整。例如:使用ThreadPoolExecutor.addShutdownHook
方法添加关闭钩子来监听线程池的关闭事件。