资讯专栏INFORMATION COLUMN

java 线程同步

xushaojieaaa / 1851人阅读

摘要:为什么线程同步当我们有多个线程要对同一个资源进行操作的时候,比如说文件,这时候就不能让多个线程同时操作这个文件了。程序完善要解决上面出现的问题,就要用到我们最开始说的线程同步了。通过这个关键字,我们就能在执行方法的时候,实现线程同步了。

为什么线程同步

当我们有多个线程要对同一个资源进行操作的时候,比如说文件,这时候就不能让多个线程同时操作这个文件了。因为当文件共享的时候,多个操作就会产生冲突。相信使用过git进行团队开发的人就会有比价深刻的体会。

这时候就需要引入线程的同步机制。

所谓同步,是指一个一个执行,也就是排队,几个线程排队执行,让线程之间有一个先来后到的关系。这样,就不会产生争抢的现象,也就不会出现冲突。

问题描述

一个有两个线程的程序,第一个线程计算2~1000之间的偶数及个数,第二个线程计算1000~2000之间的偶数及个数。

初步实现

首先,我们根据题目来设计一下实现方式。

1.定义两个线程。这里要定义自己的线程类,然后去设置计算偶数的开始和结束
2.实现计算所给范围内的偶数和偶数个数
3.执行线程

可以看到实现方式很简单。初步实现如下:

1.定义自己的线程类:
public class MyTread extends Thread {
    private int begin;          // 范围开始
    private int end;            // 范围结束

    public MyTread(int begin, int end) {
        this.begin = begin;
        this.end = end;
    }
}
2.实现计算偶数以及偶数个数
@Override
public void run() {
    this.getEven(begin, end);
}

// 获取偶数以及个数
private void getEven(int begin, int end) {
    int count = 0;
    System.out.println(begin + "~" + end + "之间的偶数为:");
    if (begin % 2 != 0) {
        begin += 1;
    }

    for (; begin <= end; begin += 2) {
        System.out.print(begin + " ");
        count++;
    }

    System.out.println();
    System.out.println("偶数个数为:" + count);
}
3.初始化线程,运行
public static void main(String[] args) {
    MyTread tread1 = new MyTread(2, 500);
    MyTread tread2 = new MyTread(500, 1000);
    tread1.start();
    tread2.start();
}

注:这里为了展示后面的效果,所以将数字范围减小。

看一下结果:

好像并不是我们想要的效果。我们想要这样的效果:

我们想要每一部分的偶数和偶数个数都在一起,但是我们实现后的效果确实两部分混乱出现的。

程序完善

要解决上面出现的问题,就要用到我们最开始说的线程同步了。

根据我们开始的介绍,发现实现同步的一个条件就是有一个共享的资源。那么我们的代码里什么是这个共享的资源呢?貌似没有。所以先创建一个。

1.建立共享资源

我们这里的共享资源完全就可以是同一个对象,所以我们就另外建立一个类,用来示例共享资源。

public class Even {}
2.然后在共享类中建立计算偶数的方法:
public class Even {
    /**
     * 获取某个范围内偶数以及个数
     * @param begin 统计开始
     * @param end   统计结束
     */
    public synchronized void getEven(int begin, int end) {
        int count = 0;
        System.out.println(begin + "~" + end + "之间的偶数为:");
        if (begin % 2 != 0) {
            begin += 1;
        }

        for (; begin <= end; begin += 2) {
            System.out.print(begin + " ");
            count++;
        }

        System.out.println();
        System.out.println("偶数个数为:" + count);
    }
}

细心的人会发现,这个方法跟我们最开始写的方法有点不同,它多了一个关键字:synchronized。通过这个关键字,我们就能在执行方法的时候,实现线程同步了。

3.最后在线程中调用共享方法
public class MyTread extends Thread {
    Even even;
    
    @Override
    public void run() {
        even.getEven(begin, end);
    }
}

这时候,我们再来执行一下:

实现了我们想要的效果。

最后,附上完整代码:

/**
 * 偶数类
 */
public class Even {
    /**
     * 获取某个范围内偶数以及个数
     * @param begin 统计开始
     * @param end   统计结束
     */
    public synchronized void getEven(int begin, int end) {
        int count = 0;
        System.out.println(begin + "~" + end + "之间的偶数为:");
        if (begin % 2 != 0) {
            begin += 1;
        }

        for (; begin <= end; begin += 2) {
            System.out.print(begin + " ");
            count++;
        }

        System.out.println();
        System.out.println("偶数个数为:" + count);
    }
}

public class MyTread extends Thread {
    Even even;
    private int begin;          // 范围开始
    private int end;            // 范围结束

    public MyTread(Even even, int begin, int end) {
        this.even = even;
        this.begin = begin;
        this.end = end;
    }

    @Override
    public void run() {
        even.getEven(begin, end);
    }

    public static void main(String[] args) {
        Even even = new Even();
        MyTread tread1 = new MyTread(even, 2, 500);
        MyTread tread2 = new MyTread(even, 500, 1000);
        tread1.start();
        tread2.start();
    }
}

文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。

转载请注明本文地址:https://www.ucloud.cn/yun/71764.html

相关文章

  • Java同步块简介

    摘要:同步块用来避免竞争。实际需要那种同步块视具体情况而定。在非同步的方法中的同步块的例子如下所示示例使用同步块构造器来标记一块代码是同步的。在同步构造器中用括号括起来的对象叫做监视器对象。他们的构造器引用同一个实例。 Java 同步块(synchronized block)用来标记方法或者代码块是同步的。Java同步块用来避免竞争。本文介绍以下内容: Java同步关键字(synchro...

    warnerwu 评论0 收藏0
  • Java中的synchronized关键字

    摘要:的关键字中的块使用关键字进行标记。由于每个类只有一个类对象存在于中,因此全局同时只有一个线程能够进入到同一个类的静态同步方法中。同步代码块使这种期望成为可能。注意同步代码块如何在括号中接受一个对象。相同的实例被传入两个不同的线程实例中。 Java的synchronized块标记一个方法或一个代码块为同步的。synchronized块能用于防止出现竞态条件。 Java的synchroni...

    lylwyy2016 评论0 收藏0
  • 线程安全

    摘要:不可变在中,不可变的对象一定是线程安全的。在里标注自己是线程安全的类,大多都不是绝对线程安全,比如某些情况下类在调用端也需要额外的同步措施。无同步方案要保证线程安全,不一定就得需要数据的同步,两者没有因果关系。 在之前学习编程的时候,有一个概念根深蒂固,即程序=算法+数据结构。数据代表问题空间中的客体,代码就用来处理这些数据,这种思维是站在计算机的角度去抽象问题和解决问题,称之为面向过...

    fuyi501 评论0 收藏0
  • JAVA线程和并发基础面试问答

    摘要:多线程和并发问题是技术面试中面试官比较喜欢问的问题之一。线程可以被称为轻量级进程。一个守护线程是在后台执行并且不会阻止终止的线程。其他的线程状态还有,和。上下文切换是多任务操作系统和多线程环境的基本特征。 多线程和并发问题是 Java 技术面试中面试官比较喜欢问的问题之一。在这里,从面试的角度列出了大部分重要的问题,但是你仍然应该牢固的掌握Java多线程基础知识来对应日后碰到的问题。(...

    dreamans 评论0 收藏0
  • JAVA线程和并发基础

    摘要:线程可以被称为轻量级进程。一个守护线程是在后台执行并且不会阻止终止的线程。其他的线程状态还有,和。上下文切换是多任务操作系统和多线程环境的基本特征。在的线程中并没有可供任何对象使用的锁和同步器。 原文:Java Multi-Threading and Concurrency Interview Questions with Answers 翻译:并发编程网 - 郑旭东 校对:方腾飞 多...

    vboy1010 评论0 收藏0
  • java并发编程学习1--基础知识

    摘要:死亡状态线程退出有可能是正常执行完成也有可能遇见异常退出。类有新建与死亡状态返回其余状态返回判断线程是否存活。线程因某些原因进入阻塞状态。执行同步代码块的过程中执行了当前线程放弃开始睡眠进入就绪状态但是不会释放锁。 【java内存模型简介 JVM中存在一个主存区(Main Memory或Java Heap Memory),Java中所有变量都是存在主存中的,对于所有线程进行共享,而每个...

    huangjinnan 评论0 收藏0

发表评论

0条评论

最新活动
阅读需要支付1元查看
<