自旋锁-Java多线程简洁

古城微笑少年丶 2023-03-13 05:23 17阅读 0赞

## **自旋锁** ##

自旋锁是采用让当前线程不停地的在循环体内执行实现的，当循环的条件被其他线程改变时 才能进入临界区。如下

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> private&nbsp;AtomicReference&lt;Thread&gt; sign&nbsp;=new&nbsp;AtomicReference&lt;&gt;(); public&nbsp;void&nbsp;lock() { Thread current&nbsp;= Thread.currentThread(); while&nbsp;(!sign.compareAndSet(null, current)) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} } public&nbsp;void&nbsp;unlock() { Thread current&nbsp;= Thread.currentThread(); sign.compareAndSet(current, null); } </td> 
 </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> public&nbsp;class&nbsp;Test implements&nbsp;Runnable { static&nbsp;int&nbsp;sum; private&nbsp;SpinLock lock; &nbsp; public&nbsp;Test(SpinLock lock) { this.lock&nbsp;= lock; } &nbsp; /** &nbsp;* @param&nbsp;args &nbsp;* @throws&nbsp;InterruptedException &nbsp;*/ public&nbsp;static&nbsp;void&nbsp;main(String[] args) throws&nbsp;InterruptedException { SpinLock lock&nbsp;= new&nbsp;SpinLock(); for&nbsp;(int&nbsp;i&nbsp;= 0; i&nbsp;&lt; 100; i++) { Test test&nbsp;= new&nbsp;Test(lock); Thread t&nbsp;= new&nbsp;Thread(test); t.start(); } &nbsp; Thread.currentThread().sleep(1000); System.out.println(sum); } &nbsp; @Override public&nbsp;void&nbsp;run() { this.lock.lock(); this.lock.lock(); sum++; this.lock.unlock(); this.lock.unlock(); } &nbsp; } &nbsp; &nbsp; 当一个线程 调用这个不可重入的自旋锁去加锁的时候没问题，当再次调用lock()的时候，因为自旋锁的持有引用已经不为空了，该线程对象会误认为是别人的线程持有了自旋锁 使用了CAS原子操作，lock函数将owner设置为当前线程，并且预测原来的值为空。unlock函数将owner设置为null，并且预测值为当前线程。 当有第二个线程调用lock操作时由于owner值不为空，导致循环一直被执行，直至第一个线程调用unlock函数将owner设置为null，第二个线程才能进入临界区。 由于自旋锁只是将当前线程不停地执行循环体，不进行线程状态的改变，所以响应速度更快。但当线程数不停增加时，性能下降明显，因为每个线程都需要执行，占用CPU时间。如果线程竞争不激烈，并且保持锁的时间段。适合使用自旋锁。 </td> 
 </tr> 
 </tbody> 
</table>