Java多线程中的竞争条件、锁以及同步的概念

竞争条件

1.竞争条件:

在java多线程中,当两个或以上的线程对同一个数据进行操作的时候,可能会产生“竞争条件”的现象。这种现象产生的根本原因是因为多个线程在对同一个数据进行操作,此时对该数据的操作是非“原子化”的,可能前一个线程对数据的操作还没有结束,后一个线程又开始对同样的数据开始进行操作,这就可能会造成数据结果的变化未知。

package com.huojg.test;

public class TestThread {  

    public static void main(String[] args) {
        // new 出一个新的对象 t
        MyThread t = new MyThread();
        /**
         * 两个线程是在对同一个对象进行操作
         */
        Thread ta = new Thread(t, "Thread-A");
        Thread tb = new Thread(t, "Thread-B");
        ta.start();
        tb.start();
    }
}  

class MyThread implements Runnable {
    // 变量 a 被两个线程共同操作,可能会造成线程竞争
    int a = 10;
    @Override
    public void run() {
        for (int i = 0; i < 5; i++) {
            a -= 1;
            try {
                Thread.sleep(1);
            } catch (InterruptedException e) {}
            System.out.println(Thread.currentThread().getName() + " → a = " + a);
        }
    }
}  

结果显示:

Thread-A → a = 8
Thread-B → a = 8
Thread-A → a = 6
Thread-B → a = 6
Thread-B → a = 4
Thread-A → a = 4
Thread-B → a = 2
Thread-A → a = 2
Thread-A → a = 0
Thread-B → a = 0

从上面的结果中我们可以看到,在线程A对数据进行了操作之后,他还没有来得及数据进行下一次的操作,此时线程B也对数据进行了操作,导致数据a一次性被减了两次,以至于a为9的时候的值根本没有打印出来,a为0的时候却被打印了两次。

那么,我们要如何才能避免结果这种情况的出现呢?

2.线程锁

如果在一个线程对数据进行操作的时候,禁止另外一个线程操作此数据,那么,就能很好的解决以上的问题了。这种操作叫做给线程加锁。

package com.huojg.test;

import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

/**
 * 在Java多线程中,当两个或以上的线程对同一个数据进行操作的时候,可能会产生“竞争条件”的现象。这种现象产生的根本原因是因为多个线程在对同一个数据进行操作,此时对该数据的操作是非“原子化”的,
 * 可能前一个线程对数据的操作还没有结束,后一个线程又开始对同样的数据开始进行操作,这就可能会造成数据结果的变化未知。
 *
 *
 * 2.线程锁

如果在一个线程对数据进行操作的时候,禁止另外一个线程操作此数据,那么,就能很好的解决以上的问题了。这种操作叫做给线程加锁。
 * */
public class TestThread {  

    public static void main(String[] args) {
        // new 出一个新的对象 t
        MyThread t = new MyThread();
        /**
         * 两个线程是在对同一个对象进行操作
         */
        Thread ta = new Thread(t, "Thread-A");
        Thread tb = new Thread(t, "Thread-B");
        ta.start();
        tb.start();
    }
}  

class MyThread implements Runnable {
    // 声明锁
    private Lock lock = new ReentrantLock();
    // 变量 a 被两个线程共同操作,可能会造成线程竞争
    int a = 10;
    @Override
    public void run() {
          // 加锁
        lock.lock();
        for (int i = 0; i < 5; i++) {
            a -= 1;
            try {
                Thread.sleep(1);
            } catch (InterruptedException e) {}
            System.out.println(Thread.currentThread().getName() + " → a = " + a);
        }
        lock.unlock();
    }
}  

运行结果:

Thread-A → a = 9
Thread-A → a = 8
Thread-A → a = 7
Thread-A → a = 6
Thread-A → a = 5
Thread-B → a = 4
Thread-B → a = 3
Thread-B → a = 2
Thread-B → a = 1
Thread-B → a = 0

上面的代码给出了给线程枷锁的方式,可以看到,在线程对数据进行操作之前先给此操作加一把锁,那么在此线程对数据进行操作的时候,其他的线程无法对此数据进行操作,只能“阻塞”在一边等待当前线程对数据操作结束后再对数据进行下一次的操作,当前线程在数据的操作完成之后会解开当前的锁以便下一个线程操作此数据

用synchronized关键字加锁来对方法进行加锁:结果一样;

总结:

Java中的多线程,当多个线程对一个数据进行操作时,可能会产生“竞争条件”的现象,这时候需要对线程的操作进行加锁,来解决多线程操作一个数据时可能产生问题。加锁方式有两种,一个是申明Lock对象来对语句快进行加锁,另一种是通过synchronized 关键字来对方法进行加锁。以上两种方法都可以有效解决Java多线程中存在的竞争条件的问题。

时间: 2024-12-25 05:29:09

Java多线程中的竞争条件、锁以及同步的概念的相关文章

Java多线程中的死锁问题[转]

//申明:本文转载自http://www.cnblogs.com/digdeep/p/4448148.html <Java多线程中的死锁问题> Java程序基本都要涉及到多线程,而在多线程环境中不可避免的要遇到线程死锁的问题.Java不像数据库那么能够检测到死锁,然后进行处理,Java中的死锁问题,只能通过程序员自己写代码时避免引入死锁的可能性来解决. 1. Java中导致死锁的原因 Java中死锁最简单的情况是,一个线程T1持有锁L1并且申请获得锁L2,而另一个线程T2持有锁L2并且申请获得

转 Java多线程中Sleep与Wait的区别

Java中的多线程是一种抢占式的机制,而不是分时机制.抢占式的机制是有多个线程处于可运行状态,但是只有一个线程在运行. 共同点: 1. 他们都是在多线程的环境下,都可以在程序的调用处阻塞指定的毫秒数,并返回. 2. wait()和sleep()都可以通过interrupt()方法 打断线程的暂停状态 ,从而使线程立刻抛出InterruptedException. 如果线程A希望立即结束线程B,则可以对线程B对应的Thread实例调用interrupt方法.如果此刻线程B正在wait/sleep/

thread.join函数,java多线程中的join函数解析

join函数的作用,是让当前线程等待,直到调用join()的 线程结束或者等到一段时间,我们来看以下代码 1 package mian; 2 3 4 public class simpleplela { 5 static void threadMessage(String message) { 6 String threadName = 7 Thread.currentThread().getName(); 8 9 System.out.println(threadName+" "+m

java多线程中join用法

thread.Join把指定的线程加入到当前线程,可以将两个交替执行的线程合并为顺序执行的线程.比如在线程B中调用了线程A的Join()方法,直到线程A执行完毕后,才会继续执行线程B. package com.wzs; /** * Java多线程中join用法 * * @author Administrator * */ public class JoinTest { public static void main(String[] args) { BThread bThread = new B

Java多线程中的Runnable和Thread

摘要: 在java中可有两种方式实现多线程,一种是继承Thread类,一种是实现Runnable接口:Thread类是在java.lang包中定义的.一个类只要继承了Thread类同时覆写了本类中的run()方法就可以实现多线程操作了,但是一个类只能继承一个父类,这是此方法的局限. 用法: Thread: package org.thread.demo;class MyThread extends Thread{ private String name; public MyThread(Stri

java多线程学习之——多线程中几种释放锁和不释放锁的操作

在学习java多线程这一块知识的时候,遇到了很多个关于线程锁什么时候释放的问题,现总结几种释放锁和不释放锁的操作如下: 不释放锁: 线程执行同步代码块或同步方法时,程序调用Thread.sleep(Long l).Thread.yield()方法暂停当前线程的执行 线程执行同步代码块时,其它线程调用该线程suspend()方法将该线程挂起,该线程不会释放锁(同步监视器) 尽量避免使用suspend()和resume()来控制线程 释放锁: 当前线程的同步方法.同步代码块执行结束 当前线程的同步方

java 多线程中的锁的类别及使用

目前在Java中存在两种锁机制: synchronized Lock Lock接口及其实现类是JDK5增加的内容,其作者是大名鼎鼎的并发专家Doug Lea. 数据同步需要依赖锁,那锁的同步又依赖谁? synchronized给出的答案是在软件层面依赖JVM, 而Lock给出的方案是在硬件层面依赖特殊的CPU指令 Synchronized 其应用层的语义是可以把任何一个非null对象作为"锁" 当synchronized作用在方法上时,锁住的便是对象实例(this): 当作用在静态方法

java 多线程(三)条件对象

转载请注明出处:http://blog.csdn.net/xingjiarong/article/details/47417383 在上一篇博客中,我们学会了用ReentrantLock来控制线程訪问同一个数据,防止出现Race Condition.这一次呢.我们继续深入的学习,学习一下java中的条件对象.条件对象在多线程同步中用到的比較多. 首先,我们来介绍一下临界区. 临界区:在同步的程序设计中.临界区指的是一个訪问共用资源的程序片段,而这些共用资源又具有无法同一时候被多个线程訪问的特性.

Java多线程中线程间的通信

一.使用while方式来实现线程之间的通信 package com.ietree.multithread.sync; import java.util.ArrayList; import java.util.List; public class MyList { private volatile static List list = new ArrayList(); public void add() { list.add("apple"); } public int size() {