在当今这个追求高效的时代,程序也需要具备 “一心多用” 的能力,这样才能充分利用计算机的资源,提高性能和响应速度。Java 的多线程编程就为我们提供了这样的能力,让程序可以同时执行多个任务。
线程的基本概念:进程与线程的 “舞蹈”
在深入了解多线程编程之前,我们先来搞清楚进程和线程的概念。
进程与线程
进程就像是一场大型演出,是程序在操作系统中的一次执行过程,是系统进行资源分配和调度的基本单位。而线程则是这场演出中的一个个演员,是进程中的一个执行单元。一个进程可以包含多个线程,这些线程共享进程的资源,如内存空间、文件句柄等,但每个线程有自己的栈空间和程序计数器。
并发与并行
并发和并行是多线程编程中两个重要的概念。并发就像是一个演员在不同的时间段内交替扮演不同的角色,宏观上看起来像是同时在进行多个表演,但微观上是串行的。并行则像是多个演员在同一时刻同时进行不同的表演,需要多核处理器的支持。
创建线程的方式:开启多线程之旅
在 Java 中,有多种方式可以创建线程。
继承Thread类
通过继承 Thread 类,并重写 run() 方法来定义线程的任务。然后创建该类的对象,并调用 start() 方法启动线程。
java
class MyThread extends Thread {
@Override
public void run() {
System.out.println("继承 Thread 类的线程正在执行");
}
}
public class ThreadExample {
public static void main(String[] args) {
MyThread myThread = new MyThread();
myThread.start();
}
}
实现Runnable接口
实现 Runnable 接口的 run() 方法,将该接口的实现类对象作为参数传递给 Thread 类的构造函数,再调用 start() 方法启动线程。
java
class MyRunnable implements Runnable {
@Override
public void run() {
System.out.println("实现 Runnable 接口的线程正在执行");
}
}
public class RunnableExample {
public static void main(String[] args) {
MyRunnable myRunnable = new MyRunnable();
Thread thread = new Thread(myRunnable);
thread.start();
}
}
实现Callable接口
Callable 接口与 Runnable 接口类似,但 Callable 接口的 call() 方法有返回值,并且可以抛出异常。需要使用 FutureTask 类来包装 Callable 对象,再将 FutureTask 对象传递给 Thread 类的构造函数启动线程。
java
import java.util.concurrent.*;
class MyCallable implements Callable<Integer> {
@Override
public Integer call() throws Exception {
return 1 + 2;
}
}
public class CallableExample {
public static void main(String[] args) throws ExecutionException, InterruptedException {
MyCallable myCallable = new MyCallable();
FutureTask<Integer> futureTask = new FutureTask<>(myCallable);
Thread thread = new Thread(futureTask);
thread.start();
Integer result = futureTask.get();
System.out.println("Callable 线程的返回结果: " + result);
}
}
线程的生命周期:一场旅程的起起落落
线程就像一个旅行者,有自己的生命周期。
新建状态(New)
当创建一个线程对象时,线程处于新建状态,此时线程还没有开始执行,就像旅行者还在准备行囊。
就绪状态(Runnable)
调用线程的 start() 方法后,线程进入就绪状态,等待 CPU 分配时间片,就像旅行者已经准备好了,在等待出发的信号。
运行状态(Running)
当 CPU 为就绪状态的线程分配时间片后,线程进入运行状态,开始执行 run() 方法中的代码,就像旅行者开始了自己的旅程。
阻塞状态(Blocked)
线程在某些情况下会进入阻塞状态,如等待 I/O 操作完成、等待获取锁等。阻塞状态的线程不会占用 CPU 资源,当阻塞条件解除后,线程会进入就绪状态,就像旅行者在路上遇到了阻碍,暂时停了下来。
死亡状态(Terminated)
线程的 run() 方法执行完毕或者抛出未捕获的异常时,线程进入死亡状态,线程生命周期结束,就像旅行者结束了自己的旅程。
线程同步:避免 “交通拥堵”
当多个线程同时访问共享资源时,可能会导致数据不一致的问题,这就像多条道路上的车辆同时争夺一个路口,容易造成 “交通拥堵”。
线程安全问题
例如,多个线程同时对一个计数器进行自增操作,可能会出现计数错误。
synchronized关键字
可以使用 synchronized 关键字来实现线程同步,保证同一时刻只有一个线程可以访问被 synchronized 修饰的代码块或方法。
java
class Counter {
private int count = 0;
public synchronized void increment() {
count++;
}
}
Lock接口
java.util.concurrent.locks.Lock 接口提供了比 synchronized 更灵活的锁机制,如 ReentrantLock。
java
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
class Counter {
private int count = 0;
private final Lock lock = new ReentrantLock();
public void increment() {
lock.lock();
try {
count++;
} finally {
lock.unlock();
}
}
}
线程通信:线程间的 “悄悄话”
线程之间也需要进行沟通,就像演员之间需要互相配合一样。
wait()、notify()和notifyAll()方法
这些方法是 Object 类的方法,用于实现线程之间的通信。wait() 方法使当前线程进入等待状态,释放对象的锁;notify() 方法唤醒在此对象监视器上等待的单个线程;notifyAll() 方法唤醒在此对象监视器上等待的所有线程。
java
class Message {
private String content;
private boolean isAvailable = false;
public synchronized void send(String content) {
while (isAvailable) {
try {
wait();
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
}
this.content = content;
isAvailable = true;
notifyAll();
}
public synchronized String receive() {
while (!isAvailable) {
try {
wait();
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
}
isAvailable = false;
notifyAll();
return content;
}
}
掌握了 Java 的多线程编程,我们就可以让程序像一个高效的团队一样,同时处理多个任务,提高程序的性能和响应速度。希望大家在编程的道路上,能够灵活运用多线程编程的技巧,创造出更加优秀的 Java 程序!
