Java 多线程编程:让程序 “一心多用”

在当今这个追求高效的时代,程序也需要具备 “一心多用” 的能力,这样才能充分利用计算机的资源,提高性能和响应速度。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 程序!

原文链接:,转发请注明来源!