理解并解决Java多线程同步问题实例-蒲公英云

理解并解决Java多线程同步问题实例

原创忘是亡心i 2024-09-15 04:48 196阅读 0赞

在Java中，多线程同步主要通过以下几种方式来实现：

synchronized关键字：用于修饰方法或代码块，保证同一时刻只有一个线程进入该区域。

// 以对象为例
object synchronizedMethod() {
    // 方法体
}
class MyClass {
    private Object lock = new Object();
    synchronized void criticalSection() {
        lock synchronized () {
            // 方法体
        }
    }
}

wait/notify：用于线程间通信，通过调用wait()和notify()方法来控制线程状态。

class LockObject {
    private boolean locked = false;
    private Object lock = new Object();
    public synchronized void lock() {
        if (locked) throw new IllegalStateException("Cannot relock");
        locked = true;
        try {
            lock synchronized () {
                // 等待其他线程释放锁，或者超时
                while (!lock.lock()) {
                    try {
                        wait();
                    } catch (InterruptedException e) {
                        Thread.currentThread().interrupt();
                        e.printStackTrace();
                    }
                }
                // 处理业务逻辑
            } finally {
                locked = false;
                notifyAll(); // 唤醒所有等待的线程
            }
        } catch (Exception e) {
            e.printStackTrace();
            locked = false; // 无论什么原因，尝试重新解锁
        }
    }
    public synchronized void unlock() {
        if (!locked) throw new IllegalStateException("Lock is not held");
        lock.unlock(); // 解锁
        locked = false;
        notifyAll();
    }
}

原子类和方法：Java 1.5引入了Atomic类，它们提供了无共享的内存访问。此外，还可以使用sun.misc.Unsafe进行原子操作。

import java.util.concurrent.atomic.AtomicInteger;
public class AtomExample {
    private AtomicInteger count = new AtomicInteger(0);
    public void increment() {
        count.incrementAndGet();
    }
    public int decrementIfZero() {
        if (count.decrementIfZero(0)) return 1;
        return 0; // 如果count变为0，说明已经减为0了
    }
}