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

共享性@H_301_3@

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

新建一个类ShareData@H_301_3@

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

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

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

获取ShareData对象，new 出来@H_301_3@

@H_301_3@

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

获取Thread对象，new出来，构造函数参数：Runable对象@H_301_3@

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

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

使用for循环100次，调用addCount()方法@H_301_3@

@H_301_3@

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

打印count变量@H_301_3@

@H_301_3@

调用Thread对象的start()方法@H_301_3@

package com.tsh.mthread;

public class Home {
    int count;

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

        for (int i = 0; i < 10; i++) {
            Thread t = new Thread( Runnable() {
                @Override
                 run() {
                    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();
        }
        // 睡三秒等等上面的
         {
            Thread.sleep(3000);
        }  (Exception e) {
            e.printStackTrace();
        }
        System.out.println("总计：" + home.count);
    }

     addCount() {
            count++;
    }
}

@H_301_3@

互斥性@H_301_3@

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

    synchronized ;
    }

@H_301_3@

使用synchronized修饰代码块@H_301_3@

     addCount() {
        synchronized (this) {
            count++;
        }
    }

@H_301_3@

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

猜你在找的Java SE相关文章