commit 507f7c7275ee989792980653a4c23372e77189de Author: life <1733802689@qq.com> Date: Sat Oct 28 14:57:21 2023 +0800 手写自旋锁 diff --git a/.gitignore b/.gitignore new file mode 100644 index 0000000..5ff6309 --- /dev/null +++ b/.gitignore @@ -0,0 +1,38 @@ +target/ +!.mvn/wrapper/maven-wrapper.jar +!**/src/main/**/target/ +!**/src/test/**/target/ + +### IntelliJ IDEA ### +.idea/modules.xml +.idea/jarRepositories.xml +.idea/compiler.xml +.idea/libraries/ +*.iws +*.iml +*.ipr + +### Eclipse ### +.apt_generated +.classpath +.factorypath +.project +.settings +.springBeans +.sts4-cache + +### NetBeans ### +/nbproject/private/ +/nbbuild/ +/dist/ +/nbdist/ +/.nb-gradle/ +build/ +!**/src/main/**/build/ +!**/src/test/**/build/ + +### VS Code ### +.vscode/ + +### Mac OS ### +.DS_Store \ No newline at end of file diff --git a/.idea/.gitignore b/.idea/.gitignore new file mode 100644 index 0000000..35410ca --- /dev/null +++ b/.idea/.gitignore @@ -0,0 +1,8 @@ +# 默认忽略的文件 +/shelf/ +/workspace.xml +# 基于编辑器的 HTTP 客户端请求 +/httpRequests/ +# Datasource local storage ignored files +/dataSources/ +/dataSources.local.xml diff --git a/.idea/encodings.xml b/.idea/encodings.xml new file mode 100644 index 0000000..aa00ffa --- /dev/null +++ b/.idea/encodings.xml @@ -0,0 +1,7 @@ + + + + + + + \ No newline at end of file diff --git a/.idea/misc.xml b/.idea/misc.xml new file mode 100644 index 0000000..82dbec8 --- /dev/null +++ b/.idea/misc.xml @@ -0,0 +1,14 @@ + + + + + + + + + + \ No newline at end of file diff --git a/.idea/vcs.xml b/.idea/vcs.xml new file mode 100644 index 0000000..94a25f7 --- /dev/null +++ b/.idea/vcs.xml @@ -0,0 +1,6 @@ + + + + + + \ No newline at end of file diff --git a/pom.xml b/pom.xml new file mode 100644 index 0000000..88597f5 --- /dev/null +++ b/pom.xml @@ -0,0 +1,17 @@ + + + 4.0.0 + + org.example + weekly + 1.0-SNAPSHOT + + + 17 + 17 + UTF-8 + + + diff --git a/src/main/java/org/example/Main.java b/src/main/java/org/example/Main.java new file mode 100644 index 0000000..cf9f6fc --- /dev/null +++ b/src/main/java/org/example/Main.java @@ -0,0 +1,45 @@ +package org.example; + +import java.util.concurrent.TimeUnit; +import java.util.concurrent.atomic.AtomicReference; + +public class Main { + AtomicReference atomicReference = new AtomicReference<>(); + + public void lock() { + Thread threadA = Thread.currentThread(); + //假如线程A先进入锁 + System.out.printf(Thread.currentThread().getName() + "\t" + "----------come in"+"\n"); + while (!atomicReference.compareAndSet(null, threadA)) { + //期望值为null 更新值为线程A自己 + //线程A持有锁成功 + } + } + + public void unlock() { + Thread threadA = Thread.currentThread(); + //线程A肯定希望出来的是自己,线程A一走锁就空了 + //使用期望值为线程A自己 更新值为null + atomicReference.compareAndSet(threadA, null); + System.out.printf(Thread.currentThread().getName() + "\t" + "----------task over,unlock"+"\n"); + + + } + + public static void main(String[] args) { + Main main = new Main(); + new Thread(() -> { + main.lock(); + //暂停几秒钟线程 + try {TimeUnit.SECONDS.sleep(5);} catch (InterruptedException e) {e.printStackTrace();} + main.unlock(); + }, "A").start(); + //线程A先于线程B启动 + try {TimeUnit.MILLISECONDS.sleep(500);} catch (InterruptedException e) {e.printStackTrace();} + new Thread(() -> { + main.lock(); + main.unlock(); + }, "B").start(); + + } +}