[javaSE] 看博客学习java并发编程

共享性

多线程操作同一个数据,产生线程安全问题

新建一个类ShareData

设计一个int 型的成员变量count

设计一个成员方法addCount(),把count变量++

在main函数中开启多个线程操作这个成员变量,在main函数里

获取ShareData对象,new 出来

使用for循环10次,在循环中开启线程,模拟10个线程并发,在循环内

获取Thread对象,new出来,构造函数参数:Runable对象

匿名内部类实现Runable接口,重写run()方法

调用Thread.sleep(1000),使线程睡眠一秒,增加出现问题的概率

使用for循环100次,调用addCount()方法

调用Thread.sleep(3),主程序睡眠3秒,保证上面的线程全部执行完了

打印count变量

调用Thread对象的start()方法

package com.tsh.mthread;

public class Home {
    public int count;

    public static void main(String[] args) {
        final Home home = new Home();

        for (int i = 0; i < 10; i++) {
            Thread t = new Thread(new Runnable() {
                @Override
                public void run() {
                    for (int j = 0; j < 100; j++) {
                        home.addCount();
                    }

                    try {
                        Thread.sleep(1000);
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                    System.out.println(Thread.currentThread()+":"+home.count);
                }
            });
            t.start();
        }
        // 睡三秒等等上面的
        try {
            Thread.sleep(3000);
        } catch (Exception e) {
            e.printStackTrace();
        }
        System.out.println("总计:" + home.count);
    }

    public void addCount() {
            count++;
    }
}

互斥性

使用synchronized关键字修饰上面的addCount()方法,当前线程操作时加把锁,同时只允许一个访问者对资源进行访问,具有唯一性和排他性

    public synchronized void addCount() {
            count++;
    }

使用synchronized修饰代码块

    public void addCount() {
        synchronized (this) {
            count++;
        }
    }
时间: 2024-08-11 01:35:23

[javaSE] 看博客学习java并发编程的相关文章

[android] 看博客学习hashCode()和equals()

equals()是Object类提供的一个方法,众所周知,每一个java类都继承自Object,所以说每一个对象都有一个equals()方法,我们在用这个方法时却一般重写这个方法 Object类中equals()方法源码 public boolean equals(Object obj) { return (this == obj); } 此时比较的是两个引用是否指向同一个对象,我们来使用这个方法的时候往往是希望比较两个对象逻辑上是否相等 String类重写了equals()方法,因此: Str

[PHP] 看博客学习插入排序

定义数组长度变量$len,使用count()函数,参数:数组 for循环数组,条件:从第二个开始,遍历数组,循环内 定义临时变量$temp,赋值当前元素 for循环数组,条件:遍历当前元素前面的所有元素 判断当前元素与它前面的元素的大小,利用临时变量,转换变量 PHP版: <?php $arr=array(2,3,4,1,5); function insert_sort($arr){ $len=count($arr); for($i=1;$i<$len;$i++){ $temp=$arr[$i

学习java并发编程的问题

/**  *   * @author weip 书中讲到计数器count是线程安全(毋庸置疑,AtomicLong是命令级的线程安全),  *         而计数器的状态就是servlet的状态,这是为何?  *  */ @ThreadSafe public class CountingFactorizer extends GenericServlet implements Servlet { private final AtomicLong count = new AtomicLong(0

[android] 看博客学习Android常见的几种RuntimeException

异常分为两种: 1.编译时异常 当编译时异常抛出时,需要对其进行处理声明,否则编译不通过 2.运行时异常 编译时不检测,运行时 如果抛出,程序会立刻停止 NullPointerException 空指针引用异常 ClassCastException 类型转换异常 IllegalArgumentException 非法参数异常 ArithmeticException 算数运算异常 IndexOutOfBoundsException 下标越界异常 NumberFormatException 数字格式

如何才能够系统地学习Java并发技术?

Java并发编程一直是Java程序员必须懂但又是很难懂的技术内容. 这里不仅仅是指使用简单的多线程编程,或者使用juc的某个类.当然这些都是并发编程的基本知识,除了使用这些工具以外,Java并发编程中涉及到的技术原理十分丰富.为了更好地把并发知识形成一个体系,也鉴于本人目前也没有能力写出这类文章,于是参考几位并发编程方面专家的博客和书籍,做一个简单的整理. 首先说一下我学习Java并发编程的一些方法吧.大概分为这几步: 1.先学会最基础的Java多线程编程,Thread类的使用,线程通信的一些方

读《Java并发编程的艺术》(一)

离开博客园很久了,自从找到工作,到现在基本没有再写过博客了.在大学培养起来的写博客的习惯在慢慢的消失殆尽,感觉汗颜.所以现在要开始重新培养起这个习惯,定期写博客不仅是对自己学习知识的一种沉淀,更是在督促自己要不断的学习,不断的进步. 最近在进一步学习Java并发编程,不言而喻,这部分内容是很重要的.现在就以<并发编程的艺术>一书为主导线,开始新一轮的学习. 进程和线程 进程是一个应用程序在处理机上的一次执行过程,线程是进程的最小基本单位(个人理解).一个进程可以包含多个线程. 上下文切换 我们

Java并发编程-一个线程的内心独白

最近正在学习Java并发编程实践,无意中发现了这篇文章,特别的有意思,而且覆盖的知识点也很多,忍不住分享给大家! 我是一个线程, 我一出生就被编了个号: 0x3704, 然后被领到一个昏暗的屋子里, 这里我发现了很多和我一模一样的同伴. 我身边的同伴0x6900 待的时间比较长, 他带着沧桑的口气对我说: 我们线程的宿命就是处理包裹. 把包裹处理完以后还得马上回到这里,否则可能永远回不来了. 我一脸懵懂,包裹,什么包裹? "不要着急,马上你就会明白了, 我们这里是不养闲人的." 果然,

【java并发编程实战】-----线程基本概念

学习Java并发已经有一个多月了,感觉有些东西学习一会儿了就会忘记,做了一些笔记但是不系统,对于Java并发这么大的"系统",需要自己好好总结.整理才能征服它.希望同仁们一起来学习Java并发编程,共同进步,互相指导. 在学习Java并发之前我们需要先理解一些基本的概念:共享.可变.线程安全性.线程同步.原子性.可见性.有序性. 共享和可变 要编写线程安全的代码,其核心在于对共享的和可变的状态进行访问. "共享"就意味着变量可以被多个线程同时访问.我们知道系统中的资

Java并发编程系列(一)-线程的基本使用

最近在学习java并发编程基础.一切从简,以能理解概念为主. 并发编程肯定绕不过线程.这是最基础的. 那么就从在java中,如何使用线程开始. 继承Thread类 继承Thread类,重写run方法,new出对象,调用start方法. 在新启的线程里运行的就是重写的run方法. 1 /** 2 * 集成Thread类 实现run() 3 */ 4 public class C1 extends Thread { 5 6 @Override 7 public void run() { 8 try