java线程同步 synchronized失效???(理解好是否上锁的是同一个对象,因为同一个对象对应的run( ) 是同一个 )

简介: java线程同步 synchronized失效???(理解好是否上锁的是同一个对象,因为同一个对象对应的run( ) 是同一个 )

java线程同步 synchronized失效???(理解好是否上锁的是同一个对象)

看是否给同一个对象上锁!

情况是1:多个线程执行同个对象,即多个运行任务的线程执行同一个任务对象

情况2:多个线程执行不同的多个对象,即多个运行任务的线程执行不同的多个任务对象

 

 

(~~~~~~~~~~~~~~~~~~第一个例子如果看不太清晰的话,请看第二个例子(是第一个例子简洁版啦,帮你理一下)~~~~~~~~~~~~~~~~~~~~~~~~~~~)

第一个例子~~~

情况一:(包括加synchronized 和 没加 synchronized 的情况:)

21.png

22.png

 

 

23.png

 

情况二:(包括加synchronized 和 没加 synchronized 的情况:)

24.png

25.png

 

26.png

 

 

 

代码:

❀ts 测试类

package eating;
public class ts {
      public static void main(String[] args){
          AppleNum appleNum = new AppleNum(20);
//          Apple apple = new Apple(appleNum);
          Apple[] apple = new Apple[5];
          String[] names = { "小红", "小黄", "小蓝", "小绿", "小青" };
          for(int i = 0; i < names.length; i++) {
              apple[i] = new Apple(appleNum);
              new Thread(apple[i], names[i]).start();
          }
      }
}
❀AppleNum 苹果数量类:
package eating;
public class AppleNum {
    /* 苹果数量 */
    int num;
    public AppleNum(int num) {
        this.num = num;
    }
    public int getNum() {
        return num;
    }
    public int setNum(int num2) {
        return num -= num2;
    }
}

❀Apple 苹果类

package eating;
import java.util.concurrent.TimeUnit;
class Apple implements Runnable {
    private AppleNum appleNum;
    public Apple(AppleNum appleNum) {
        this.appleNum = appleNum;
    }
    @Override
    public void run() {
        while (true) {
            synchronized (this) {
                if (appleNum.getNum() > 0) {
                    System.out.println(Thread.currentThread().getName() + "拿了第" + appleNum.setNum(1) + "个苹果");
                    try {
                        TimeUnit.MILLISECONDS.sleep(100);
                    } catch (InterruptedException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                }
            }
        }
    }
}

不好意思是不是把你绕晕了。。。。。。先看一下第二个例子先,然后咱再分析第一例子的情况

第二个例子~~

~~~~~~~~~第二个例子(理一下多线程竞争的情况~~~同一个对象、不同个对象!!!)

❀TeacherApple 类

package SendApple;
public class TeacherApple implements Runnable{
    private int apples = 5;
    public void run() {
        while (true) {
            if (apples > 0) {
                Thread th = Thread.currentThread();
                String th_name = th.getName();
                System.out.println(th_name + "正在发第" + apples-- + "个苹果");
            }
        }
   }
}

 

✿ 情况一:不同执行任务的线程执行的是同一个对象:

package SendApple;
public class Apple {
    public static void main(String[] args) {
        String names[] = {"李老师", "张老师", "徐老师"};
        TeacherApple theacherApple = new TeacherApple();   //theacherApple 是后边执行的同一个对象
        for(int i = 0; i < names.length; i++) {
            new Thread(theacherApple, names[i]).start();     //不同执行任务的线程执行的是同一个对象:theacherApple
        }
    }
}

27.png

 

 

 

✿ 情况二:不同执行任务的线程执行的是不同的多个对象:

package SendApple;
public class Apple {
    public static void main(String[] args) {
        String names[] = {"李老师", "张老师", "徐老师"};
        TeacherApple[] theacherApple = new TeacherApple[3];    //是后边执行的不同的多个对象
        for(int i = 0; i < names.length; i++) {
            theacherApple[i] = new TeacherApple();
            new Thread(theacherApple[i], names[i]).start();    //不同执行任务的线程执行的是不同的多个对象:
        }
    }
}

 

 

 

28.png

 

 

总结一下:

多线程特点:不断的竞争抢资源。

同一个对象用不同线程执行:相当于不同线程里去竞争同一个对象里边的资源。

不同对象用不同的线程去执行:相当于线程A执行A对象的资源,线程B执行线程B对象的资源,线程的关系永远是竞争关系。

 

例子二分析:

对象内部run() 方法 要求打印的那个语句被执行5次。

例子二:第一种情况:只有一个对象,则只有一个run() 方法。3个 线程们竞争的姿态来到同一对象的run() 方法里的 同一个语句时,抢该对象run() 方法的该语句的执行,直到该对象被不同线程执行的次数之和是5次结束。

例子二:第二种情况:有个5个对象,则有5个run()方法。newThread(theacherApple[i], names[i]).start(); 则一个线程负责一个对象的run() 方法。每个线程都有对应的负责对象的run() 方法,然后run() 方法里的 打印语句5次的执行

 

 

例子一分析:

关于线程同步问题在于面对同一份资源时,出现了数据错误情况(非线程安全)

同一个资源:(共享资源)··························ApppleNum对象 ,在main 方法里它是只建立一次的,所以它在内存中位置不变,然后在apple的构造方法里被作为参数传入。

这里要注意不管是建立了多个Apple 对象 还是 一个 Apple 对象时,ApppleNum对象 (共享资源)的 数量都是一,是它是它,就是它!

 

 

情况一的分析

只有一个对象时,只有一个run() 方法。

同一对象(Apple)里边有 同一个 对象属性 (ApppleNum),run() 方法是:要求苹果数( appleNum.getNum() > 0 ),  没加 synchronized 时, 多个线程启动了同一个Apple的同一个run() 方法时,因为 咱的唯一 ApppleNum对象 的数量 被不同线程看到那一刻数量可能都是(例如 20),然后 如果不加关键字,则咱不同线程要纷纷对咱的唯一 ApppleNum对象的数量进行减少并打印,不加锁的话,则线程们都看到时可能看到的数据是同一个(例如都是20),导致线程A(在20的基础上)减少1后,线程B也是(在20的基础上)减少1,导致数据出错啦!

加锁:线程A进去门被琐住了,其他线程在外面等待,线程A看到(假设ApppleNum对象的数量是20),减少1 后,解锁,然后线程B 再进去,再锁上,然后看到,然后减1。。。。。。

 

情况二的分析:

五个对象时,有五个不同的run() 方法呀。

不同对象(Apple[ i ] )的run() 方法使用不同线程启动,假设 线程A 启动的是 Apple【0】对象的run() 方法,然后 对咱的唯一 ApppleNum对象的数量进行减少1并打印,加不加锁头时,影响不到问题实质。例如不加锁头,五个run()方法对应的5个线程执行对共享资源(咱的唯一 ApppleNum对象的数量),进行减1并打印,5个run()方法对应的线程同时竞争到这里。例如加锁头,五个run() 方法对应的线程竞争到那里都是锁一下的动作,然后还是执行对共享资源(咱的唯一 ApppleNum对象的数量),进行减1并打印

 

总结:打个比方:

一个对象,一个run() 方法,相当于 同一个厕所的门,五个线程来到同一个厕所的门,如果(厕所)没有锁上,五个线程都想上厕所,一个线程进去了其他线程还能进去,就会出现线程们都挤到厕所里,如果(厕所)有 锁上,一个线程进去了其他线程进不去,在外面等待。然后。。。。(穷人厕所,多人上)

五个对象,五个run() 方法相当于 五个厕所的门,五个线程站在自己对应的厕所门那里,如果门开了,各自进各自的厕所,(这时候啊,那一扇厕所门,外面就他一个人,没有其他人!!!即私人专享vip 厕所),门没有锁,他进去该干嘛就干嘛,门有锁了,他进去该干嘛还是干嘛。。。。。(vip 厕所,私人专上)

同一份资源(共享资源):相当厕所的冲厕所的那一桶水,谁上完厕所,厕所都要冲水,不管是哪个厕所(穷人厕所,多人上 还是 vip 厕所,私人专上),上完厕所,就要冲水。

 

 

ps:线程安全?非线程安全?什么是线程同步?

线程安全?线程不安全?

线程不安全:在不提供加锁机制保护时,出现了多个线程先后更新数据所得的数据是脏数据。举例子:买票时,如果不排队,抢着买票,A看到票数是100(B也马上看到了,在A买之前,B看到的票数也是100),A买了,则站在A的角度,这时候票数更新为99,然后B也来买,则站在B的角度,票数应该为99(因为B看到的票数是100). 明明被买了两张票,结果票数却是99.

什么是线程同步?~~ synchronized 关键字、线程加锁

线程同步:当线程们访问同一个共享资源时,需要通过线程同步机制,当第一个线程进去时,就把共享资源进行加锁,然后同步资源的状态给后边进去的线程。 线程同步的是把前一个线程更新后的状态传递给下一位线程。

✿ 线程同步其实实现的是线程排队防止线程同步访问共享资源造成冲突变量需要同步,常量不需要(常量存放于方法区)。

目录
相关文章
|
1天前
|
监控 Java
java异步判断线程池所有任务是否执行完
通过上述步骤,您可以在Java中实现异步判断线程池所有任务是否执行完毕。这种方法使用了 `CompletionService`来监控任务的完成情况,并通过一个独立线程异步检查所有任务的执行状态。这种设计不仅简洁高效,还能确保在大量任务处理时程序的稳定性和可维护性。希望本文能为您的开发工作提供实用的指导和帮助。
31 17
|
12天前
|
Java
Java—多线程实现生产消费者
本文介绍了多线程实现生产消费者模式的三个版本。Version1包含四个类:`Producer`(生产者)、`Consumer`(消费者)、`Resource`(公共资源)和`TestMain`(测试类)。通过`synchronized`和`wait/notify`机制控制线程同步,但存在多个生产者或消费者时可能出现多次生产和消费的问题。 Version2将`if`改为`while`,解决了多次生产和消费的问题,但仍可能因`notify()`随机唤醒线程而导致死锁。因此,引入了`notifyAll()`来唤醒所有等待线程,但这会带来性能问题。
Java—多线程实现生产消费者
|
14天前
|
安全 Java Kotlin
Java多线程——synchronized、volatile 保障可见性
Java多线程中,`synchronized` 和 `volatile` 关键字用于保障可见性。`synchronized` 保证原子性、可见性和有序性,通过锁机制确保线程安全;`volatile` 仅保证可见性和有序性,不保证原子性。代码示例展示了如何使用 `synchronized` 和 `volatile` 解决主线程无法感知子线程修改共享变量的问题。总结:`volatile` 确保不同线程对共享变量操作的可见性,使一个线程修改后,其他线程能立即看到最新值。
|
14天前
|
消息中间件 缓存 安全
Java多线程是什么
Java多线程简介:本文介绍了Java中常见的线程池类型,包括`newCachedThreadPool`(适用于短期异步任务)、`newFixedThreadPool`(适用于固定数量的长期任务)、`newScheduledThreadPool`(支持定时和周期性任务)以及`newSingleThreadExecutor`(保证任务顺序执行)。同时,文章还讲解了Java中的锁机制,如`synchronized`关键字、CAS操作及其实现方式,并详细描述了可重入锁`ReentrantLock`和读写锁`ReadWriteLock`的工作原理与应用场景。
|
14天前
|
安全 Java 编译器
深入理解Java中synchronized三种使用方式:助您写出线程安全的代码
`synchronized` 是 Java 中的关键字,用于实现线程同步,确保多个线程互斥访问共享资源。它通过内置的监视器锁机制,防止多个线程同时执行被 `synchronized` 修饰的方法或代码块。`synchronized` 可以修饰非静态方法、静态方法和代码块,分别锁定实例对象、类对象或指定的对象。其底层原理基于 JVM 的指令和对象的监视器,JDK 1.6 后引入了偏向锁、轻量级锁等优化措施,提高了性能。
40 3
|
14天前
|
存储 安全 Java
Java多线程编程秘籍:各种方案一网打尽,不要错过!
Java 中实现多线程的方式主要有四种:继承 Thread 类、实现 Runnable 接口、实现 Callable 接口和使用线程池。每种方式各有优缺点,适用于不同的场景。继承 Thread 类最简单,实现 Runnable 接口更灵活,Callable 接口支持返回结果,线程池则便于管理和复用线程。实际应用中可根据需求选择合适的方式。此外,还介绍了多线程相关的常见面试问题及答案,涵盖线程概念、线程安全、线程池等知识点。
97 2
|
22天前
|
安全 Java API
java如何请求接口然后终止某个线程
通过本文的介绍,您应该能够理解如何在Java中请求接口并根据返回结果终止某个线程。合理使用标志位或 `interrupt`方法可以确保线程的安全终止,而处理好网络请求中的各种异常情况,可以提高程序的稳定性和可靠性。
46 6
|
1月前
|
安全 算法 Java
Java多线程编程中的陷阱与最佳实践####
本文探讨了Java多线程编程中常见的陷阱,并介绍了如何通过最佳实践来避免这些问题。我们将从基础概念入手,逐步深入到具体的代码示例,帮助开发者更好地理解和应用多线程技术。无论是初学者还是有经验的开发者,都能从中获得有价值的见解和建议。 ####
|
1月前
|
Java 调度
Java中的多线程编程与并发控制
本文深入探讨了Java编程语言中多线程编程的基础知识和并发控制机制。文章首先介绍了多线程的基本概念,包括线程的定义、生命周期以及在Java中创建和管理线程的方法。接着,详细讲解了Java提供的同步机制,如synchronized关键字、wait()和notify()方法等,以及如何通过这些机制实现线程间的协调与通信。最后,本文还讨论了一些常见的并发问题,例如死锁、竞态条件等,并提供了相应的解决策略。
51 3
|
1月前
|
监控 Java 开发者
深入理解Java中的线程池实现原理及其性能优化####
本文旨在揭示Java中线程池的核心工作机制,通过剖析其背后的设计思想与实现细节,为读者提供一份详尽的线程池性能优化指南。不同于传统的技术教程,本文将采用一种互动式探索的方式,带领大家从理论到实践,逐步揭开线程池高效管理线程资源的奥秘。无论你是Java并发编程的初学者,还是寻求性能调优技巧的资深开发者,都能在本文中找到有价值的内容。 ####