Java中解决多线程数据安全问题
2024-09-04 03:25:14
同步代码块
基本语句
synchronized (任意对象) {
操作共享代码
}
代码示例
public class SellTicket implements Runnable {
private int tickets = 100;
private Object object = new Object();
@Override
public void run() {
while (true) {
synchronized (object) {
if (tickets > 0) {
try {
Thread.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName() + "正在出售第" + tickets + "张票");
tickets--;
}
}
}
}
public static void main(String[] args) {
SellTicket sellTicket = new SellTicket();
Thread thread1 = new Thread(sellTicket, "窗口1");
Thread thread2 = new Thread(sellTicket, "窗口2");
Thread thread3 = new Thread(sellTicket, "窗口3");
thread1.start();
thread2.start();
thread3.start();
}
}
优缺点：
- 解决了多线程的数据安全问题
- 多线程时，每个线程都会判断同步上的锁，耗费资源，降低了程序的运行效率
同步方法
同步方法：将synchronized关键字加到方法上
- 格式: 修饰符 synchronized 返回值类型 方法名(){ }
- 同步方法的锁对象是this
同步静态方法，就是把synchronized关键字加到静态方法上
- 格式: 修饰符 static synchronized 返回值类型 方法名(){ }
- 同步静态方法的锁对象是 类名.class
代码示例
public class SellTicket implements Runnable {
// private int tickets = 100;
private static int tickets = 100;
private Object object = new Object();
private int x = 0;
@Override
public void run() {
while (true) {
if (x % 2 == 0) {
// synchronized (object) {
// synchronized (this) {
synchronized (SellTicket.class) {
if (tickets > 0) {
try {
Thread.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName() + "正在出售第" + tickets + "张票");
tickets--;
}
}
} else {
// synchronized (object) {
// if (tickets > 0) {
// try {
// Thread.sleep(100);
// } catch (InterruptedException e) {
// e.printStackTrace();
// }
// System.out.println(Thread.currentThread().getName() + "正在出售第" + tickets + "张票");
// tickets--;
// }
// }
sellTicket();
}
x++;
}
}
// private void sellTicket(){
// synchronized (object) {
// if (tickets > 0) {
// try {
// Thread.sleep(100);
// } catch (InterruptedException e) {
// e.printStackTrace();
// }
// System.out.println(Thread.currentThread().getName() + "正在出售第" + tickets + "张票");
// tickets--;
// }
// }
// }
// private synchronized void sellTicket(){
// if (tickets > 0) {
// try {
// Thread.sleep(100);
// } catch (InterruptedException e) {
// e.printStackTrace();
// }
// System.out.println(Thread.currentThread().getName() + "正在出售第" + tickets + "张票");
// tickets--;
// }
private static synchronized void sellTicket(){
if (tickets > 0) {
try {
Thread.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName() + "正在出售第" + tickets + "张票");
tickets--;
}
}
public static void main(String[] args) {
SellTicket sellTicket = new SellTicket();
Thread thread1 = new Thread(sellTicket, "窗口1");
Thread thread2 = new Thread(sellTicket, "窗口2");
Thread thread3 = new Thread(sellTicket, "窗口3");
thread1.start();
thread2.start();
thread3.start();
}
}
lock锁
lock实现提供比使用synchronized方法和语句可获得更广泛的操作
- void lock()获得锁
- void unlock()释放
lock是接口不能直接实例化，采用实现类实例化ReentrantLock
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
public class SellTicket implements Runnable {
private int tickets = 100;
private Object object = new Object();
private Lock lock = new ReentrantLock();
@Override
public void run() {
while (true) {
try {
lock.lock();
if (tickets > 0) {
try {
Thread.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName() + "正在出售第" + tickets + "张票");
tickets--;
}
} finally {
lock.unlock();
}
}
}
public static void main(String[] args) {
SellTicket sellTicket = new SellTicket();
Thread thread1 = new Thread(sellTicket, "窗口1");
Thread thread2 = new Thread(sellTicket, "窗口2");
Thread thread3 = new Thread(sellTicket, "窗口3");
thread1.start();
thread2.start();
thread3.start();
}
}
最新文章
- form-line 样式 让 两个控件在同一个水平位置
- 【BZOJ】2078: [POI2004]WYS
- mui
- 轻量linux-Crunch bang
- 来，让我们谈一谈Normalize.css
- 机器人学 —— 机器人感知（Gaussian Model）
- max_user_connections 与 max_connections,max_connect_errors, nr_open, file-max
- table tr分离并加圆角和阴影
- Scala学习笔记--特质trait
- MySQL导入sql 文件的5大步骤
- springMVC3学习(八)--全局的异常处理
- Zabbix 监控rabbitmq
- 第一个shell脚本 结合计划任务下载远程文件
- SQL作业二
- .net core 环境安装失败，错误：0x80072EE2
- 手动编译安装nginx
- 简介 - MongoDB
- JVM-String.intern()
- href=#与href=javascript:void(0)的区别
- linux命令学习之：mv