legongju.com
我们一直在努力
2025-01-18 04:28 | 星期六

java wait()方法如何与notify()配合

在Java中,wait()notify()方法是Object类的成员方法,主要用于多线程编程中的线程间通信。wait()方法会使当前线程等待,直到其他线程调用同一对象的notify()方法。notify()方法会唤醒在该对象监视器上等待的单个线程。这两个方法必须在一个同步代码块或同步方法中使用,以确保线程安全。

以下是一个简单的示例,说明如何使用wait()notify()方法:

public class SharedResource {
    private boolean resourceAvailable = false;

    public synchronized void waitForResource() throws InterruptedException {
        System.out.println(Thread.currentThread().getName() + " is waiting for the resource.");
        wait(); // 当前线程等待,直到资源可用
        System.out.println(Thread.currentThread().getName() + " has acquired the resource.");
    }

    public synchronized void releaseResource() {
        System.out.println(Thread.currentThread().getName() + " is releasing the resource.");
        resourceAvailable = true;
        notify(); // 唤醒等待资源的线程
    }
}

public class WorkerThread extends Thread {
    private SharedResource sharedResource;

    public WorkerThread(SharedResource sharedResource) {
        this.sharedResource = sharedResource;
    }

    @Override
    public void run() {
        try {
            sharedResource.waitForResource();
            // 在此处执行使用资源的操作
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

public class Main {
    public static void main(String[] args) {
        SharedResource sharedResource = new SharedResource();

        WorkerThread workerThread1 = new WorkerThread(sharedResource);
        WorkerThread workerThread2 = new WorkerThread(sharedResource);

        workerThread1.start();
        workerThread2.start();

        try {
            Thread.sleep(2000); // 等待一段时间,以便两个线程都能启动并尝试获取资源
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        sharedResource.releaseResource();
    }
}

在这个示例中,我们有一个名为SharedResource的类,它包含一个布尔变量resourceAvailablewaitForResource()方法用于等待资源可用,而releaseResource()方法用于释放资源。当releaseResource()被调用时,它会唤醒一个正在等待资源的线程。

WorkerThread类是一个继承自Thread的类,它实现了run()方法。在run()方法中,我们调用waitForResource()方法来等待资源。

main()方法中,我们创建了两个WorkerThread实例,并启动它们。然后,我们让主线程休眠一段时间,以便两个工作线程都能启动并尝试获取资源。最后,我们调用releaseResource()方法来释放资源,唤醒一个等待的线程。

未经允许不得转载 » 本文链接:https://www.legongju.com/article/44380.html

相关推荐

  • Java编程:stdin的多线程处理

    Java编程:stdin的多线程处理

    在Java编程中,可以使用多线程来处理stdin(标准输入),以实现并发处理输入数据的功能。以下是一个简单的示例代码,演示了如何使用多线程处理stdin输入数据:

  • Java中如何实现声音的录制与播放

    Java中如何实现声音的录制与播放

    在Java中实现声音的录制与播放可以使用JavaSound API。以下是一个简单的示例代码:
    录制声音:
    import javax.sound.sampled.*; public class AudioRec...

  • Java sound编程实战技巧分享

    Java sound编程实战技巧分享

    在Java中实现音频处理和播放可以使用Java Sound API。下面是一些Java Sound编程的实战技巧: 使用AudioSystem类来获取音频输入和输出设备。可以使用getMixerInfo...

  • 如何在Java应用中集成声音功能

    如何在Java应用中集成声音功能

    在Java应用中集成声音功能可以使用Java内置的音频库javax.sound,以下是一些基本步骤: 导入javax.sound包:在代码中导入javax.sound包中的相关类。 import java...

  • c++ mkdir函数如何设置安全属性

    c++ mkdir函数如何设置安全属性

    在C++中,您可以使用mkdir函数创建目录
    #include #include #include #include bool setSecureAttributes(const std::string& path, mode_t attributes) { /...

  • c++ mkdir函数如何跨平台使用

    c++ mkdir函数如何跨平台使用

    为了在C++中创建一个跨平台的mkdir函数,您可以使用C++17的文件系统库()。这个库提供了一个跨平台的create_directory函数,可以在不同的操作系统上创建目录。以...

  • c++ mkdir函数如何处理已存在目录

    c++ mkdir函数如何处理已存在目录

    在C++中,mkdir函数是用于创建新目录的。如果指定的目录已经存在,mkdir函数会失败并返回一个错误代码。为了处理这种情况,你可以使用以下方法: 检查mkdir函数的...

  • java异常机制如何设计异常层次

    java异常机制如何设计异常层次

    设计Java异常层次结构时,需要考虑以下几个方面: 标准异常类:Java提供了许多标准异常类,这些类通常位于java.lang包中。例如,NullPointerException、IndexOut...