-
Java线程同步操作
synchronized
作用于对象实例:对给定对象加锁,进入同步代码前要获得给定对象的锁。
作用于实例方法:相当于对当前实例加锁,进入同步代码前要获得当前实例的锁。
作用于静态方法:相当于对当前类加锁,进入同步代码前要获得当前类的锁。
使用
给实例对象加锁
public class AccountingSync implements Runnable {
static AccountingSync instance = new AccountingSync();
static int i = 0;
@Override
public void run() {
for (int k = 0; k < 10000; k++) {
synchronized (instance) {
i++;
}
}
}
@Test
public void testInteger() throws InterruptedException {
int count = 10;
Thread[] ts = new Thread[count];
for (int k = 0; k < count; k++) {
ts[k] = new Thread(instance);
}
// start
for (int k = 0; k < count; k++) {
ts[k].start();
}
// join
for (int k = 0; k < count; k++) {
ts[k].join();
}
System.out.println(i);
}
}
给类方法加锁
public class AccountingSync2 implements Runnable {
static AccountingSync2 instance = new AccountingSync2();
static int i = 0;
public synchronized void increase() {
i++;
}
@Override
public void run() {
for (int k = 0; k < 10000; k++) {
increase();
}
}
@Test
public void testInteger() throws InterruptedException {
int count = 10;
Thread[] ts = new Thread[count];
for (int k = 0; k < count; k++) {
ts[k] = new Thread(instance);
}
// start
for (int k = 0; k < count; k++) {
ts[k].start();
}
// join
for (int k = 0; k < count; k++) {
ts[k].join();
}
System.out.println(i);
}
}
给类方法加锁的错误演示
public class AccountingSyncBad implements Runnable {
static int i = 0;
public synchronized void increase() {
i++;
}
@Override
public void run() {
for (int k = 0; k < 10000; k++) {
increase();
}
}
@Test
public void testInteger() throws InterruptedException {
int count = 10;
Thread[] ts = new Thread[count];
for (int k = 0; k < count; k++) {
ts[k] = new Thread(new AccountingSyncBad());
}
// start
for (int k = 0; k < count; k++) {
ts[k].start();
}
// join
for (int k = 0; k < count; k++) {
ts[k].join();
}
System.out.println(i);
}
}
假设把给类实例加锁中的每个实例比作一个门,上面的测试方法中每个门都有锁但是10个门10把锁,每个线程进一个门。还是不能保证临界区资源i同时只一个线程访问
fix
@Test
public void testIntegerFix() throws InterruptedException {
int count = 10;
AccountingSyncBad instance = new AccountingSyncBad();
Thread[] ts = new Thread[count];
for (int k = 0; k < count; k++) {
ts[k] = new Thread(instance);
}
// start
for (int k = 0; k < count; k++) {
ts[k].start();
}
// join
for (int k = 0; k < count; k++) {
ts[k].join();
}
System.out.println(i);
}
给静态类方法加锁
public class AccountingSyncClass implements Runnable {
static int i = 0;
public static synchronized void increase() {
i++;
}
@Override
public void run() {
for (int k = 0; k < 10000; k++) {
increase();
}
}
@Test
public void testInteger() throws InterruptedException {
int count = 10;
Thread[] ts = new Thread[count];
for (int k = 0; k < count; k++) {
ts[k] = new Thread(new AccountingSyncClass());
}
// start
for (int k = 0; k < count; k++) {
ts[k].start();
}
// join
for (int k = 0; k < count; k++) {
ts[k].join();
}
System.out.println(i);
}
@Test
public void testIntegerFix() throws InterruptedException {
int count = 10;
AccountingSyncClass instance = new AccountingSyncClass();
Thread[] ts = new Thread[count];
for (int k = 0; k < count; k++) {
ts[k] = new Thread(instance);
}
// start
for (int k = 0; k < count; k++) {
ts[k].start();
}
// join
for (int k = 0; k < count; k++) {
ts[k].join();
}
System.out.println(i);
}
}
上面测试的testInteger方法和testIntegerFix方法都能得到正确的结果,原因是给静态类方法加锁相当于10个门用的同一把锁,保证了同一时间只有一个线程能访问临界区资源i。
出处:https://www.cnblogs.com/okokabcd/p/8496417.html
栏目列表
最新更新
80386学习(二) 80386特权级保护
80386学习(一) 80386CPU介绍
8086汇编语言学习(十) 8086中断
8086汇编语言学习(九) 8086标志寄存器
8086汇编语言学习(九) 8086标志寄存器
8086汇编语言学习(八) 8086子程序
8086汇编语言学习(六) 8086处理结构化数据
8086汇编语言学习(五) 8086寻址方式
8086汇编语言学习(四) 8086汇编程序的编译
8086汇编语言学习(三) 8086中的段和栈
三大常用数据库事务详解之三:事务运行
三大常用关系型数据库事务详解之二:基
三大关系型数据库事务详解之一:基本概
MongoDB常用命令(2)
MongoDB基本介绍与安装(1)
SQLServer触发器调用JavaWeb接口
SQL Server索引的原理深入解析
SqlServer2016模糊匹配的三种方式及效率问题
SQL中Truncate的用法
sqlserver 多表关联时在where语句中慎用tri
在vscode中使用R时,用快捷键来快捷键入卡
VB.NET中如何快速访问注册表
ASP.NET中图象处理过程详解
Vue(1)Vue安装与使用
JavaScript 语言入门
js将一段字符串的首字母转成大写
纯原生html编写的h5视频播放器
H5仿原生app短信验证码vue2.0组件附源码地
TypeScript(4)接口
TypeScript(3)基础类型