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

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

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

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

```java
// 以对象为例
object synchronizedMethod() {
    // 方法体
}

class MyClass {
    private Object lock = new Object();

synchronized void criticalSection() {
        lock synchronized () {
            // 方法体
        }
    }
}
```

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

```java
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();
    }
}
```

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

```java
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了
    }
}
```

以上实例展示了Java多线程同步的一些常见方法。在实际应用中，可能需要根据具体需求选择合适的方法。