legongju.com
我们一直在努力
2025-01-17 18:09 | 星期五

java wait()方法如何进行多线程协作

在Java中,wait()方法是Object类的一个方法,用于让当前线程等待,直到其他线程调用该对象的notify()notifyAll()方法。在多线程协作中,wait()notify()/notifyAll()方法是非常重要的,它们允许线程之间进行有效的通信和协作。

以下是一个简单的示例,展示了如何使用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); // 让主线程休眠2秒,以便其他线程有机会运行
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        sharedResource.releaseResource(); // 释放资源
    }
}

在这个示例中,我们有一个名为SharedResource的类,它包含一个布尔变量resourceAvailable和一个同步方法waitForResource()waitForResource()方法使用wait()让当前线程等待,直到资源可用。另一个同步方法releaseResource()将资源设置为可用,并使用notify()通知等待的线程。

WorkerThread类继承了Thread类,并在其run()方法中调用waitForResource()方法。在main()方法中,我们创建了两个WorkerThread实例,并启动它们。主线程休眠2秒,以便其他线程有机会运行。然后,主线程调用releaseResource()方法释放资源,这将导致等待的线程继续执行。

这个示例展示了如何使用wait()notify()方法进行多线程协作。在实际应用中,你可能需要根据具体需求调整代码。

未经允许不得转载 » 本文链接:https://www.legongju.com/article/44386.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...

  • java wait()方法如何进行超时等待

    java wait()方法如何进行超时等待

    在Java中,wait()方法可以与synchronized关键字和Object.notify()或Object.notifyAll()方法一起使用来实现线程间的通信。当你想要让一个线程等待一段时间,然后再...

  • java的变量如何定义作用域

    java的变量如何定义作用域

    在Java中,变量的作用域是指变量在程序中可以被访问和使用的区域。根据变量的可见性和生命周期,Java中的变量可以分为以下几种作用域: 局部变量(Local Variabl...

  • java wait()方法如何避免虚假唤醒

    java wait()方法如何避免虚假唤醒

    在Java中,wait()方法可能会导致虚假唤醒,即线程在等待某个条件满足时被唤醒,但该条件实际上并未满足。为了避免虚假唤醒,通常需要结合使用synchronized关键字...

  • java wait()方法如何确保线程安全

    java wait()方法如何确保线程安全

    wait() 方法是 Java 中的一个同步机制,用于让当前线程等待,直到其他线程调用同一个对象的 notify() 或 notifyAll() 方法。为了确保线程安全,你需要遵循以下几...