Java并发——各类互斥技术的效率比较

    既然Java包括老式的synchronized关键字和Java SE5中心的Lock和Atomic类,那么比较这些不同的方式,更多的理解他们各自的价值和适用范围,就会显得很有意义。

    比较天真的方式是在针对每种方式都执行一个简单的测试,就像下面这样:

1import java.util.concurrent.locks.Lock; 2import java.util.concurrent.locks.ReentrantLock; 3 4abstract class Incrementable { 5    protected long counter = 0; 6    public abstract void increment(); 7} 8 9class SynchronizingTest extends Incrementable { 10    public synchronized void increment() { ++counter; } 11} 12 13class LockingTest extends Incrementable { 14    private Lock lock = new ReentrantLock(); 15    public void increment() { 16        lock.lock(); 17        try { 18            ++counter; 19        } finally { 20            lock.unlock(); 21        } 22    } 23} 24 25public class SimpleMicroBenchmark { 26    static long test(Incrementable inc) { 27        long start = System.nanoTime(); 28        for (long i = 0; i < 10000000; i++) { 29            inc.increment(); 30        } 31        return System.nanoTime() - start; 32    } 33    public static void main(String[] args) { 34        long syncTime = test(new SynchronizingTest()); 35        long lockTime = test(new LockingTest()); 36        System.out.println(String.format("Synchronized: %1$10d", syncTime)); 37        System.out.println(String.format("Lock: %1$10d", lockTime)); 38        System.out.println(String.format( 39            "Lock/Synchronized: %1$.3f", lockTime/(double)syncTime)); 40    } 41}

执行结果(样例):

1Synchronized:  209403651 2Lock:  257711686 3Lock/Synchronized: 1.231

    从输出中可以看到,对synchronized方法的调用看起来要比使用ReentrantLock快,这是为什么呢?

    本例演示了所谓的“微基准测试”危险,这个属于通常指在隔离的、脱离上下文环境的情况下对某个个性进行性能测试。当然,你仍旧必须编写测试来验证诸如“Lock比synchronized更快”这样的断言,但是你需要在编写这些测试的时候意识到,在编译过程中和在运行时实际会发生什么。

    上面的示例存在着大量的问题。首先也是最重要的是,我们只有在这些互斥存在竞争的情况下,才能看到真正的性能差异,因此必须有多个任务尝试访问互斥代码区。而在上面的示例中,每个互斥都由单个的main()线程在隔离的情况下测试的。

    其次,当编译器看到synchronized关键字时,有可能会执行特殊的优化,甚至有可能会注意到这个程序时单线程的。编译器甚至可能会识别出counter被递增的次数是固定数量的,因此会预先计算出其结果。不同的编译器和运行时系统在这方面存在着差异,因此很难确切了解将会发生什么,但是我们需要防止编译器去预测结果的可能性。

    为了创建有效的测试,我们必须把程序设计得更加复杂。首先,我们需要多个任务,但并不只是会修改内部值的任务,还包括读取这些值的任务(否则优化器可以识别出这些值从来不会被使用)。另外,计算必须足够复杂和不可预测,以使得编译器没有机会执行积极优化。这可以通过预加载一个大型的随机int数组(预加载可以减小在主循环上调用Random.nextInt()所造成的影响),并在计算总和时使用它们来实现:

1import java.util.Random; 2import java.util.concurrent.CyclicBarrier; 3import java.util.concurrent.ExecutorService; 4import java.util.concurrent.Executors; 5import java.util.concurrent.atomic.AtomicInteger; 6import java.util.concurrent.atomic.AtomicLong; 7import java.util.concurrent.locks.Lock; 8import java.util.concurrent.locks.ReentrantLock; 9 10abstract class Accumulator { 11    public static long cycles = 50000L; 12    // Number of modifiers and readers during each test 13    private static final int N = 4; 14    public static ExecutorService exec = Executors.newFixedThreadPool(2 * N); 15    private static CyclicBarrier barrier = new CyclicBarrier(2 * N + 1); 16    protected volatile int index = 0; 17    protected volatile long value = 0; 18    protected long duration = 0; 19    protected String id = ""; 20    // A big int array 21    protected static final int SIZE = 100000; 22    protected static int[] preLoad = new int[SIZE]; 23    static { 24        // Load the array of random numbers: 25        Random random = new Random(47); 26        for (int i = 0; i < SIZE; i++) { 27            preLoad[i] = random.nextInt(); 28        } 29    } 30    public abstract void accumulate(); 31    public abstract long read(); 32    private class Modifier implements Runnable { 33        public void run() { 34            for (int i = 0; i < cycles; i++) { 35                accumulate(); 36            } 37            try { 38                barrier.await(); 39            } catch (Exception e) { 40                throw new RuntimeException(e); 41            } 42        } 43    } 44    private class Reader implements Runnable { 45        private volatile long value; 46        public void run() { 47            for (int i = 0; i < cycles; i++) { 48                value = read(); 49            } 50            try { 51                barrier.await(); 52            } catch (Exception e) { 53                throw new RuntimeException(e); 54            } 55        } 56    } 57    public void timedTest() { 58        long start = System.nanoTime(); 59        for (int i = 0; i < N; i++) { 60            exec.execute(new Modifier());//4 Modifiers 61            exec.execute(new Reader());//4 Readers 62        } 63        try { 64            barrier.await(); 65        } catch (Exception e) { 66            throw new RuntimeException(e); 67        } 68        duration = System.nanoTime() - start; 69        System.out.println(String.format("%-13s: %13d", id, duration)); 70    } 71     72    public static void report(Accumulator a1, Accumulator a2) { 73        System.out.println(String.format("%-22s: %.2f", a1.id +  74            "/" + a2.id, a1.duration / (double)a2.duration)); 75    } 76} 77 78class BaseLine extends Accumulator { 79    {id = "BaseLine";} 80    public void accumulate() { 81        value += preLoad[index++]; 82        if (index >= SIZE - 5) index = 0; 83    } 84 85    public long read() { return value; } 86} 87 88class SynchronizedTest extends Accumulator { 89    {id = "Synchronized";} 90    public synchronized void accumulate() { 91        value += preLoad[index++]; 92        if (index >= SIZE - 5) index = 0; 93    } 94     95    public synchronized long read() { return value; } 96} 97 98class LockTest extends Accumulator { 99    {id = "Lock";} 100    private Lock lock = new ReentrantLock(); 101    public void accumulate() { 102        lock.lock(); 103        try { 104            value += preLoad[index++]; 105            if (index >= SIZE - 5) index = 0; 106        } finally { 107            lock.unlock(); 108        } 109    } 110     111    public long read() {  112        lock.lock(); 113        try { 114            return value;  115        } finally { 116            lock.unlock(); 117        } 118    } 119} 120 121class AtomicTest extends Accumulator { 122    {id = "Atomic"; } 123    private AtomicInteger index = new AtomicInteger(0); 124    private AtomicLong value = new AtomicLong(0); 125    public void accumulate() { 126        //Get value before increment. 127        int i = index.getAndIncrement(); 128        //Get value before add. 129        value.getAndAdd(preLoad[i]); 130        if (++>= SIZE - 5) index.set(0); 131    } 132 133    public long read() {return value.get(); } 134} 135 136public class SynchronizationComparisons { 137    static BaseLine baseLine = new BaseLine(); 138    static SynchronizedTest synchronizedTest = new SynchronizedTest(); 139    static LockTest lockTest = new LockTest(); 140    static AtomicTest atomicTest = new AtomicTest(); 141    static void test() { 142        System.out.println("============================"); 143        System.out.println(String.format( 144            "%-13s:%14d", "Cycles", Accumulator.cycles)); 145        baseLine.timedTest(); 146        synchronizedTest.timedTest(); 147        lockTest.timedTest(); 148        atomicTest.timedTest(); 149        Accumulator.report(synchronizedTest, baseLine); 150        Accumulator.report(lockTest, baseLine); 151        Accumulator.report(atomicTest, baseLine); 152        Accumulator.report(synchronizedTest, lockTest); 153        Accumulator.report(synchronizedTest, atomicTest); 154        Accumulator.report(lockTest, atomicTest); 155    } 156    public static void main(String[] args) { 157        int iterations = 5;//Default execute time 158        if (args.length > 0) {//Optionally change iterations 159            iterations = Integer.parseInt(args[0]); 160        } 161        //The first time fills the thread pool 162        System.out.println("Warmup"); 163        baseLine.timedTest(); 164        //Now the initial test does not include the cost 165        //of starting the threads for the first time. 166        for (int i = 0; i < iterations; i++) { 167            test(); 168            //Double cycle times. 169            Accumulator.cycles *= 2; 170        } 171        Accumulator.exec.shutdown(); 172    } 173}

执行结果(样例):

1Warmup 2BaseLine     :      12138900 3============================ 4Cycles       :         50000 5BaseLine     :      12864498 6Synchronized :      87454199 7Lock         :      27814348 8Atomic       :      14859345 9Synchronized/BaseLine : 6.80 10Lock/BaseLine         : 2.16 11Atomic/BaseLine       : 1.16 12Synchronized/Lock     : 3.14 13Synchronized/Atomic   : 5.89 14Lock/Atomic           : 1.87 15============================ 16Cycles       :        100000 17BaseLine     :      25348624 18Synchronized :     173022095 19Lock         :      51439951 20Atomic       :      32804577 21Synchronized/BaseLine : 6.83 22Lock/BaseLine         : 2.03 23Atomic/BaseLine       : 1.29 24Synchronized/Lock     : 3.36 25Synchronized/Atomic   : 5.27 26Lock/Atomic           : 1.57 27============================ 28Cycles       :        200000 29BaseLine     :      47772466 30Synchronized :     348437447 31Lock         :     104095347 32Atomic       :      59283429 33Synchronized/BaseLine : 7.29 34Lock/BaseLine         : 2.18 35Atomic/BaseLine       : 1.24 36Synchronized/Lock     : 3.35 37Synchronized/Atomic   : 5.88 38Lock/Atomic           : 1.76 39============================ 40Cycles       :        400000 41BaseLine     :      98804055 42Synchronized :     667298338 43Lock         :     212294221 44Atomic       :     137635474 45Synchronized/BaseLine : 6.75 46Lock/BaseLine         : 2.15 47Atomic/BaseLine       : 1.39 48Synchronized/Lock     : 3.14 49Synchronized/Atomic   : 4.85 50Lock/Atomic           : 1.54 51============================ 52Cycles       :        800000 53BaseLine     :     178514302 54Synchronized :    1381579165 55Lock         :     444506440 56Atomic       :     300079340 57Synchronized/BaseLine : 7.74 58Lock/BaseLine         : 2.49 59Atomic/BaseLine       : 1.68 60Synchronized/Lock     : 3.11 61Synchronized/Atomic   : 4.60 62Lock/Atomic           : 1.48

    这个程序使用了模板方法设计模式,将所有的共用代码都放置到基类中,并将所有不同的代码隔离在子类的accumulate()和read()的实现中。在每个子类SynchronizedTest、LockTest和AtomicTest中,你可以看到accumulate()和read()如何表达了实现互斥现象的不同方式。

    在这个程序中,各个任务都是经由FixedThreadPool执行的,在执行过程中尝试着在开始时跟踪所有线程的创建,并且在测试过程中方式产生任何额外的开销。为了保险起见,初始测试执行了两次,而第一次的结果被丢弃,因为它包含了初试线程的创建。

    程序中有一个CyclicBarrier,因为我们希望确保所有的任务在声明每个测试完成之前都已经完成。

    每次调用accumulate()时,它都会移动到preLoad数组的下一个位置(到达数组尾部时在回到开始位置),并将这个位置的随机生成的数字加到value上。多个Modifier和Reader任务提供了在Accumulator对象上的竞争。

    注意,在AtomicTest中,我发现情况过于复杂,使用Atomic对象已经不适合了——基本上,如果涉及多个Atomic对象,你就有可能会被强制要求放弃这种用法,转而使用更加常规的互斥(JDK文档特别声明:当一个对象的临界更新被限制为只涉及单个变量时,只有使用Atomic对象这种方式才能工作)。但是,这个测试仍旧保留了下来,使你能够感受到Atomic对象的性能优势。

    在main()中,测试时重复运行的,并且你可以要求其重复的次数超过5次,对于每次重复,测试循环的数量都会加倍,因此你可以看到当运行次数越来越多时,这些不同的互斥在行为方面存在着怎样的差异。正如你从输出中看到的那样,测试结果相当惊人。抛开预加载数组、初始化线程池和线程的影响,synchronized关键字的效率明显比Lock和Atomic的低。

    记住,这个程序只是给出了各种互斥方式之间的差异的趋势,而上面的输出也仅仅表示这些差异在我的特定环境下的特定机器上的表现。如你所见,如果自己动手实验,当所有的**线程数量不同,或者程序运行的时间更长时,在行为方面肯定会存在着明显的变化。**例如,某些hotspot运行时优化会在程序运行后的数分钟之后被调用,但是对于服务器端程序,这段时间可能长达数小时。

    也就是说,很明显,使用Lock通常会比使用synchronized高效许多,而且synchronized的开销看起来变化范围太大,而Lock则相对一致

    这是否意味着你永远不应该选择synchronized关键字呢?这里有两个因素需要考虑:首先,在上面的程序中,**互斥方法体是非常小的。**通常,这是一个好的习惯——只互斥那些你绝对必须互斥的部分。但是,在实际中,被互斥部分可能会比上面示例中的那些大许多,因此在这些方法体中花费的时间的百分比可能会明显大于进入和退出互斥的开销,这样也就湮没了提高互斥速度带来的所有好处。当然,唯一了解这一点的方式是——当你在对性能调优时,应该立即——尝试各种不同的方法并观察它们造成的影响。

    其次,在阅读本文的代码你就会发现,很明显,synchronized关键字所产生的代码,与Lock所需要的“加锁-try/finally-解锁”惯用法所产生的代码量相比,可读性提高了很多。在编程时,与其他人交流对于与计算机交流而言要重要得多,因此代码的可读性至关重要。因此,在编程时,以synchronized关键字入手,只有在性能调优时才替换为Lock对象这种做法,是具有实际意义的。

    最后,当你在自己的并发程序中可以使用Atomic类时,这肯定非常好,但是要意识到,正如我们在上例中看到的,Atomic对象只有在非常简单的情况下才有用,这些情况通常包括你只有一个要被修改的Atomic对象,并且这个对象独立于其他所有的对象。更安全的做法是:以更加传统的方式入手,只有在性能方面的需求能够明确指示时,才替换为Atomic。

点赞
收藏

评论区

加载中...

相关推荐

MySQL:[Err] 1292 - Incorrect datetime value: ‘0000-00-00 00:00:00‘ for column ‘CREATE_TIME‘ at row 1

文章目录问题用navicat导入数据时,报错:原因这是因为当前的MySQL不支持datetime为0的情况。解决修改sql\mode:sql\mode:SQLMode定义了MySQL应支持的SQL语法、数据校验等,这样可以更容易地在不同的环境中使用MySQL。全局s

Oracle 分组与拼接字符串同时使用

SELECTT.,ROWNUMIDFROM(SELECTT.EMPLID,T.NAME,T.BU,T.REALDEPART,T.FORMATDATE,SUM(T.S0)S0,MAX(UPDATETIME)CREATETIME,LISTAGG(TOCHAR(

MySQL部分从库上面因为大量的临时表tmp_table造成慢查询

背景描述Time:20190124T00:08:14.70572408:00User@Host:@Id:Schema:sentrymetaLast_errno:0Killed:0Query_time:0.315758Lock_

皕杰报表之UUID

​在我们用皕杰报表工具设计填报报表时,如何在新增行里自动增加id呢?能新增整数排序id吗?目前可以在新增行里自动增加id,但只能用uuid函数增加UUID编码,不能新增整数排序id。uuid函数说明:获取一个UUID,可以在填报表中用来创建数据ID语法:uuid()或uuid(sep)参数说明:sep布尔值,生成的uuid中是否包含分隔符'',缺省为

手写Java HashMap源码

HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程22

KVM调整cpu和内存

一.修改kvm虚拟机的配置1、virsheditcentos7找到“memory”和“vcpu”标签,将<namecentos7</name<uuid2220a6d1a36a4fbb8523e078b3dfe795</uuid