java 多线程 计数

题目

给定count=0；让5个线程并发累加到1000；

思路

创建一个类MyRunnable，实现Runnable（继承Thread类也可）
定义一个公共变量count(初始值为0)，5个线程都可以访问到；
创建5个线程并发递增count到1000；

注意

这块注意Thread和Runnable类的区别，Thread类是线程类，可以直接new Thread().start运行。而Runnable类是任务类，需要一个线程来承载任务，通过new Thread(new Runnable()).start()来运行任务。

方法

方法一

将count公共变量放到测试类Test的类成员变量里，将MyRunnable类作为Test类的内部类，在Test类的main方法里创建5个线程，实现累加。

代码

public class Test {//公共变量int count=0;public static void main(String[] args){//new一个实现Runnable的类Test test=new Test();//创建5个任务MyRunnable myRunnable1=test.new MyRunnable();MyRunnable myRunnable2=test.new MyRunnable();MyRunnable myRunnable3=test.new MyRunnable();MyRunnable myRunnable4=test.new MyRunnable();MyRunnable myRunnable5=test.new MyRunnable();//创建5个线程new Thread(myRunnable1).start();new Thread(myRunnable2).start();new Thread(myRunnable3).start();new Thread(myRunnable4).start();new Thread(myRunnable5).start();}//创建一个实现Runnable的类class MyRunnable implements Runnable{public void run() {while(true){//锁住的是整个MyRunnable类synchronized(MyRunnable.class){if(count>=1000){break;}System.out.println(Thread.currentThread().getName()+":count:"+(++count));//测试时，线程更容易切换Thread.yield();}}}}}

方法二

以上代码没有问题，成功实现5个线程累加count到1000，接下来我们将上边代码稍作修改。

将5个线程执行5个任务，修改为5个线程执行同一任务。
将synchronized(MyRunnable.class)修改为synchronized(this)

代码

public class Test {//公共变量int count=0;public static void main(String[] args){//new一个实现Runnable的类Test test=new Test();//创建1个任务MyRunnable myRunnable1=test.new MyRunnable();
//      MyRunnable myRunnable2=test.new MyRunnable();
//      MyRunnable myRunnable3=test.new MyRunnable();
//      MyRunnable myRunnable4=test.new MyRunnable();
//      MyRunnable myRunnable5=test.new MyRunnable();//创建5个线程for(int i=0;i<4;i++){new Thread(myRunnable1).start();}
//      new Thread(myRunnable2).start();
//      new Thread(myRunnable3).start();
//      new Thread(myRunnable4).start();
//      new Thread(myRunnable5).start();}//创建一个实现Runnable的类class MyRunnable implements Runnable{public void run() {while(true){//锁住的是同一对象synchronized(this){if(count>=1000){break;}System.out.println(Thread.currentThread().getName()+":count:"+(++count));//测试时，线程更容易切换Thread.yield();}}}}}

以上代码没有问题，成功实现5个线程累加count到1000。

虽然结果是一样的，但是代码实现是不一样的，代码一是创建了5个MyRunnable对象，代码二只创建了1个MyRunnable对象。考虑并发时用到的锁就是不一样的，

代码一和代码二虽然synchronized中的锁不同，但目的都是为了括号中的锁是恒定不变的。

synchronized(this)代表锁是this对象，代码二中之所以可以使用this，是因为几个线程使用的this都是同一个对象。
synchronized(MyRunnable.class)代表锁是MyRunnable.class.this，因为MyRunnable.class.this是类加载到静态方法区中，是一直存在不变的，代码一中可以使用，当然代码二也可以这样写。
代码一和代码二可以使用更通用的方式就是专门new一个锁对象，这个锁对象可以放在类成员变量里，加上static就可以一直常存。如定义成public static Object lock=new Object();代码一和代码二都可以使用synchronized(lock)来加锁。synchronized(this)这种方式主要是因为书写方便。

方法三

使用AtomicInteger类，来实现多线程累加，AtomicInteger类是线程安全的，使用它的优点就是我们不需要在代码里写Synchronized关键字了，这些事都交给它去做了。

代码

public class Test {static CountDownLatch cdl=new CountDownLatch(1000);;static AtomicInteger ai=new AtomicInteger(0);public static void main(String[] args) throws InterruptedException{ ExecutorService exec=Executors.newFixedThreadPool(100);for (int i = 0; i < 1000; i++) {exec.execute(new Runnable() {@Overridepublic void run() {System.out.println(Thread.currentThread().getName()+":"+ai.getAndIncrement());cdl.countDown();}});}cdl.await();System.out.println(ai.get());exec.shutdown();}
}

代码中用到了CountDownLatch类，用法就是给其设定一个初始值1000，然后在不同线程中执行countDown方法，每执行一次，初始值-1,await方法就是等初始值减到0时，停止等待，否则一直等待。

我在代码里新建了100个线程来并发累加，让我们看下最后结果。

控制台输出如下：

可以看到虽然输出不是按照顺序输出的，但是最后的结果是我们想要的结果，没有出现重复值的情况。

总结

这到题目只是举了一个多线程的例子，以及锁的简单知识。在实际应用中，从0累加到1000用多线程是没有意义的。因为根本不会比单线程快。就像让一个人数数，从0数到1000，或者让5个人接替数到1000，应该一个人更快点吧，5个人还要考虑配合的问题。但假如这5个人都是磕巴（口语不好），一个人每读一个数都要停顿1秒，但是让5个人协作，省去中间的等待时间，才是多线程应用的真正意义。
多线程的真正应用应该是，任务中有等待的时间，这个等待时间如果交给一个线程做就堵塞在这块了。如果交由多个线程去做，会充分利用等待时间，去做其他事情。这才是多线程的意思。在我们日常工作中，像IO，网络，图片处理等，有些地方都是需要等待的，这几块用多线程，可能会提高效率。

当然，也有一种情况，比如多个用户访问后台接口，每个用户访问其实都是一个单独的线程，假如想计算累计有多少次访问的话，就需要用到多线程累加。

参考资料

深入理解synchronized(synchronized锁住的是代码还是对象)

深入理解java并发之sychronized实现原理

java中Sychronized用法

java多线程累加计数相关推荐

【26天高效学习Java编程】Day19：60 多个实例讲解，彻底搞懂Java 多线程【可查阅，可复习，可面试】
本专栏将从基础开始,循序渐进,由浅入深讲解Java的基本使用,希望大家都能够从中有所收获,也请大家多多支持. 专栏地址:26天高效学习Java编程相关软件地址:软件地址所有代码地址:代码地址如果 ...
当初我要是这么学习Java多线程就好了「附图文解析」
文章目录 1. 概念篇 1.1 认识进程 1.2 进程性质 1.3 操作系统如何管理进程 1.4 多线程和多进程 1.5 时间片 1.6 并发与并行 1.7 内核态与用户态 1.8 进程中的上下文 1 ...
Java多线程发展简史
摘自: http://www.raychase.net/698 这篇文章,大部分内容,是周五我做的一个关于如何进行Java多线程编程的Knowledge Sharing的一个整理,我希望能对Java从 ...
实现 Java 多线程并发控制框架
2006 年 8 月 14 日 Java 提供了语言级别的线程支持,所以在 Java 中使用多线程相对于 C,C++ 来说更简单便捷,但本文并不是介绍如何在 Java 中使用多线程来来解决诸如 Web ...
Java多线程 - AQS详解
介绍 AQS是java.util.concurrent.locks下类AbstractQueuedSynchronizer的简称,是用于通过Java源码来构建多线程的锁和同步器的一系列框架,用于Ja ...
[转] Java多线程发展简史
这篇文章,大部分内容,是周五我做的一个关于如何进行Java多线程编程的Knowledge Sharing的一个整理,我希望能对Java从第一个版本开始,在多线程编程方面的大事件和发展脉络有一个描述,并 ...
Java多线程——线程的优先级和生命周期
Java多线程--线程的优先级和生命周期摘要:本文主要介绍了线程的优先级以及线程有哪些生命周期. 部分内容来自以下博客: https://www.cnblogs.com/sunddenly/p/41 ...
java多线程系列(四)---ReentrantLock的使用
Lock的使用前言:本系列将从零开始讲解java多线程相关的技术,内容参考于<java多线程核心技术>与<java并发编程实战>等相关资料,希望站在巨人的肩膀上,再通过我的理 ...
java多线程学习-java.util.concurrent详解
http://janeky.iteye.com/category/124727 java多线程学习-java.util.concurrent详解(一) Latch/Barrier 博客分类: java ...

java多线程累加计数

题目

思路

注意

方法

方法一

代码

方法二

代码

方法三

代码

总结

同类型文章

参考资料

java多线程累加计数相关推荐

最新文章

热门文章