java 多线程并发问题

问题：50个线程，先查询数据库的一个记录 t，然后对这个记录+1，最后更新到数据库

（更新的时候，不允许使用 update test_concurrent set sum =sum -1 where id=1,如果这个做就看不出来效果了，必须使用update test_concurrent set sum =？ where id=1）。

1.创建表

CREATE TABLE `test_concurrent` (
`id` bigint(20) NOT NULL AUTO_INCREMENT,
`sum` bigint(20) DEFAULT NULL COMMENT '并发的和',
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8;

2.表里只有一条记录

INSERT INTO `test_concurrent` VALUES (1, 0);

对于这种并发问题有三种解决方法

1.使用悲观锁 select for update

2.使用乐观锁新增一个字段，查询时设置这个字段，更新时根据这个字段更新

3.update test_concurrent set sum =? where id=1 and sum =#{t}

4.update test_concurrent set sum =sum-? where id=1 and sum >=?

总和来说：4是最好的写法。

并发线程代码

@Test

    public void testAdd1() {

        log.info("开始执行----------------");

        CountDownLatch latch = new CountDownLatch(50);

        ExecutorService executor=new ThreadPoolExecutor(10, 50, 2000, TimeUnit.SECONDS, new ArrayBlockingQueue(50));

        AtomicInteger integer=new AtomicInteger(0);

        for(int i=0;i<50;i++){

            Integer s=i;

            executor.execute(new Runnable() {

                @Override

                public void run() {

                    //log.info("开始执行----------------{}",s);

                    service.add1(1);

                    log.info("开始执行----------------{}",s);

                    integer.incrementAndGet();

                    latch.countDown();

                }

            });

        }

        try {

            latch.await();

        } catch (InterruptedException e1) {

            // TODO Auto-generated catch block

            e1.printStackTrace();

        }

        log.info("开始执行----------------{}",integer.intValue());

注意：线程池的用法

巴特西

java 多线程并发问题

最新文章

热门文章