在Java中,新建线程可以通过实现Runnable接口或者继承Thread类来创建。为了同步线程,你可以使用以下方法:
在需要同步的方法或代码块上添加synchronized关键字。这将确保同一时间只有一个线程可以访问该方法或代码块。
class MyRunnable implements Runnable {
private final Object lock = new Object();
@Override
public void run() {
synchronized (lock) {
// 需要同步的代码
}
}
}
或者
class MyThread extends Thread {
private final Object lock = new Object();
@Override
public void run() {
synchronized (lock) {
// 需要同步的代码
}
}
}
Java提供了Lock接口和ReentrantLock类来实现显式锁定。使用这些工具可以更灵活地控制锁的获取和释放。
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
class MyRunnable implements Runnable {
private final Lock lock = new ReentrantLock();
@Override
public void run() {
lock.lock(); // 获取锁
try {
// 需要同步的代码
} finally {
lock.unlock(); // 释放锁
}
}
}
或者
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
class MyThread extends Thread {
private final Lock lock = new ReentrantLock();
@Override
public void run() {
lock.lock(); // 获取锁
try {
// 需要同步的代码
} finally {
lock.unlock(); // 释放锁
}
}
}
注意:在使用Lock接口时,确保在finally代码块中释放锁,以防止死锁。