• linkedu视频
  • 平面设计
  • 电脑入门
  • 操作系统
  • 办公应用
  • 电脑硬件
  • 动画设计
  • 3D设计
  • 网页设计
  • CAD设计
  • 影音处理
  • 数据库
  • 程序设计
  • 认证考试
  • 信息管理
  • 信息安全
菜单
linkedu.com
  • 网页制作
  • 数据库
  • 程序设计
  • 操作系统
  • CMS教程
  • 游戏攻略
  • 脚本语言
  • 平面设计
  • 软件教程
  • 网络安全
  • 电脑知识
  • 服务器
  • 视频教程
  • JavaScript
  • ASP.NET
  • PHP
  • 正则表达式
  • AJAX
  • JSP
  • ASP
  • Flex
  • XML
  • 编程技巧
  • Android
  • swift
  • C#教程
  • vb
  • vb.net
  • C语言
  • Java
  • Delphi
  • 易语言
  • vc/mfc
  • 嵌入式开发
  • 游戏开发
  • ios
  • 编程问答
  • 汇编语言
  • 微信小程序
  • 数据结构
  • OpenGL
  • 架构设计
  • qt
  • 微信公众号
您的位置:首页 > 程序设计 >Java > 浅谈Java多线程实现及同步互斥通讯

浅谈Java多线程实现及同步互斥通讯

作者: 字体:[增加 减小] 来源:互联网 时间:2017-05-28

通过本文主要向大家介绍了浅谈java,浅谈,浅谈小学语文阅读教学,浅谈如何转化后进生,浅谈小学数学教学方法等相关知识,希望对您有所帮助,也希望大家支持linkedu.com www.linkedu.com

Java多线程深入理解本文主要从三个方面了解和掌握多线程:

1. 多线程的实现方式,通过继承Thread类和通过实现Runnable接口的方式以及异同点。

2. 多线程的同步与互斥中synchronized的使用方法。

3. 多线程的通讯中的notify(),notifyAll(),及wait(),的使用方法,以及简单的生成者和消费者的代码实现。

下面来具体的讲解Java中的多线程:

一:多线程的实现方式

通过继承Threa类来实现多线程主要分为以下三步:

第一步:继承 Thread,实现Thread类中的run()方法。

第二步:定义一个Thread子类的实例。

第三步:通过调用Thread类的start()方法来启动线程。

下面是简单的代码实现:

class myThread extends Thread{
  int n=100;
  public void run() {
    while (true) {
    if (n > 0) {
System.out.println(":"Thread.currentThread().getName()
              + "..." + n--);
        } else {
          break;
        }
      }
  }

}
public class ThreadTest {

  public static void main(String[] args) {
    myThread mythread=new myThread();
    mythread.setName("子线程");
    mythread.start();
  }

}
</div>

上面线程中用到的几个方法:Thread.currentThraed().getName()方法得到当前线程的名字。mythread.setName(“子线程”);为mythread线程重命名为“子线程”。

通过实现Runnable 接口来实现多线程主要分为以下几步:

第一步:实现Runnable接口中的run()方法。生成一个Runnable的实例。

第二步:定义一个Thread类,并且将上面的Runnable实例传给Thread类的构造方法。

第三步:通过调用Thread类的start()方法来启动线程。

下面是简单的代码实现:

class myRunnable implements Runnable{
  int n=100;
  public void run() {
    while (true) {
    if (n > 0) {
System.out.println(":"Thread.currentThread().getName()
              + "..." + n--);
        } else {
          break;
        }
      }
  }
}
public class ThreadTest {

  public static void main(String[] args) {
    myRunnable myrunnable = new myRunnable();
    Thread mythread=new Thread(myrunnable);
    mythread.setName("子线程");
    mythread.start();
  }
}
</div>

既然通过继承Thread类,和实现Runnable方法都能实现多线程的运行那么两种方式到底有什么不同呢?下面通过一个买票的类子来看看到底二者有什么不同:

假设售票处总共有100张票,通过三个窗口来进行售票也就是说我们要开辟三个不同的线程来实现买票:首先看看通过Thread类来实现买票的方式:

class myThread extends Thread{
  int n=100;
  public void run() {
    while (true) {
    if (n > 0) {
System.out.println(":"Thread.currentThread().getName()
              + "..." + n--);
        } else {
          break;
        }
      }
  }
}
public class ThreadTest {
  public static void main(String[] args) {
    myThread m1=new myThread();
    myThread m2=new myThread();
    myThread m3=new myThread();
    m1.setName("窗口1");
    m2.setName("窗口2");
    m3.setName("窗口3");
    m1.start();
    m2.start();
    m3.start();
  }
}

</div>

结果太长了我不展示了,可以看到原本三个窗口共同买100张票的,但是结果每个窗口都买了100张票,这个很好理解因为每个窗口都是一个独立的对象,都有自己的n=100。所以通过Thread类来实现买票功能是不可行的,其实用Thread方法来实现多线程,其中每个线程执行的代码并不是同一段代码。

下面来看看实现Runnable接口是怎样实现买票功能的:

class myRunnable implements Runnable{
  int n=100;
  public void run() {
    while (true) {
    if (n > 0) {
System.out.println(":"Thread.currentThread().getName()
              + "..." + n--);
        } else {
          break;
        }
      }
  }
}
public class ThreadTest {
  public static void main(String[] args) {
    myRunnable myrunnable=new myRunnable();
    Thread m1=new Thread(myrunnable);
    Thread m2=new Thread(myrunnable);
    Thread m3=new Thread(myrunnable);
    m1.setName("窗口1");
    m2.setName("窗口2");
    m3.setName("窗口3");
    m1.start();
    m2.start();
    m3.start();
  }
}

</div>

可以看出上面三个线程公用的是同一个Runnable的子类,所以只是开辟三条线程来执行同一段runnable的代码。所以不会出现买300张票的情况。但是这个程序还是有问题的当讲到了后面的线程的同步与互斥后我们再来完善这段程序。

二:多线程的同步与互斥中synchronized和volatile的使用方法。

现在截取一段上面代码执行过程中出现的问题并且分析一下问题是如何产生的,再来通过synchronied来解决此问题。

:窗口2…1
:窗口1…1
:窗口3…1
:窗口1…2
:窗口2…2
:窗口1…3
:窗口3…2
:窗口1…4
:窗口2…3
:窗口1…5
:窗口3…3
:窗口1…6
:窗口2…4

上面代码的结果是通过实现Runnable接口产生的,上面窗口1,窗口2,窗口3,同时产生1是怎么产生的呢?

  int n=100;
  public void run() {
    while (true) {
    if (n > 0) {
System.out.println(":"Thread.currentThread().getName()
              + "..." + n--);
        } else {
          break;
        }
      }

</div>

这是三个线程共同执行的同一段代码,上面结果产生的一种原因可能是当窗口2执行完输出i=1时此时虚拟机执行了窗口2,窗口2执行输出I,此时的i还未执行++,所以i的值还是1,此时虚拟机又把执行权给了窗口3,这个时候窗口3输出的i仍然是1,程序产生上面问题的主要原因是存在公共变量i,i的值在程序执行的过程中未保持同步。上面的for循环体应该单独执行完之后才能让其他的线程抢占虚拟机。Synchronized关键字就是用来实现保证线程在执行一段公共资源是不被其他线程抢占。

被synchronized修饰的代码块称作同步代码块,被synchronized修饰的方法称为同步方法。下面通过加入synchronized关键字来实现买票功能:

class myRunnable implements Runnable {
  int n = 100;

  public void run() {
    while (true) {
      synchronized (this) {
        if (n > 0) {
          if (n % 10 == 0) {
            try {
              Thread.currentThread().sleep(10);
            } catch (InterruptedException e) {
              // TODO Auto-generated catch block
              e.printStackTrace();
            }
          }
          System.out.println(":" + Thread.currentThread().getName()
              + "..." + n--);
        } else {
          break;
        }
      }
    }
  }
}

public class ThreadTest {
  public static void main(String[] args) {
    myRunnable myrunnable = new myRunnable();
    Thread m1 = new Thread(myrunnable);
    Thread m2 = new Thread(myrunnable);
    Thread m3 = new Thread(myrunnable);
    m1.setName("窗口1");
    m2.setName("窗口2");
    m3.setName("窗口3");
    m1.start();
    m2.start();
    m3.start();
  }
}

</div>

此时是可以正确的完成售票功能的。

上面代码中synchronized(this)中的this代表的是当前的对象,因为三个线程执行的都是myRunnable 的对象,所以三个线程公用的是同一个锁,其实这个this可以用任何的对象来代替,一般我们可以 String str=new String(“”);虽然str的值为空字符串,但是也是一个对象。Synchronized实现互斥的原理是每一个对象都有一个特定的变量值,当任何一个线程调用了synchronized想要进入公共资源区时,先判断该变量的值,若该变量的值为0则可以进入公共资源区,进程在进入公共资源区之前先把对象的中的该变量值变为1,出同步区后再将该变量的值变为0,从而实现线程互斥访问公共资源。

三:多线程的通讯中的notify(),notifyAll(),及wait(),的使用方法,以及简单的生成者和消费者的代码实现。

在讲解notify(),notifyAll(),wait()之前,先看看生产者和消费者问题:生产者生产面包,消费

分享到:QQ空间新浪微博腾讯微博微信百度贴吧QQ好友复制网址打印

您可能想查找下面的文章:

  • 浅谈java中的对象、类、与方法的重载
  • 浅谈java中为什么实体类需要实现序列化
  • 浅谈java中OO的概念和设计原则(必看)
  • 浅谈java中的一维数组、二维数组、三维数组、多维数组
  • 浅谈java里的EL表达式在JSP中不能解析的问题
  • 浅谈Java多线程实现及同步互斥通讯
  • 浅谈Java中几个常用集合添加元素的效率
  • 浅谈java中的路径表示
  • 浅谈对java中锁的理解
  • 浅谈java对象转json,数字精确出现丢失问题

相关文章

  • 2017-05-28Java数据结构之图(动力节点Java学院整理)
  • 2017-05-28详解用Kotlin写一个基于Spring Boot的RESTful服务
  • 2017-05-28Java使用字节流复制文件的方法
  • 2017-05-28SWT(JFace)体验之GridLayout布局
  • 2017-05-28java 中Map详解及实例代码
  • 2017-05-28Java List简介_动力节点Java学院整理
  • 2017-05-28Servlet实现多文件上传功能
  • 2017-05-28Java从网络读取图片并保存至本地实例
  • 2017-08-27ReentrantLock源码分析(二)
  • 2017-05-28SWT(JFace)体验之FillLayout布局

文章分类

  • JavaScript
  • ASP.NET
  • PHP
  • 正则表达式
  • AJAX
  • JSP
  • ASP
  • Flex
  • XML
  • 编程技巧
  • Android
  • swift
  • C#教程
  • vb
  • vb.net
  • C语言
  • Java
  • Delphi
  • 易语言
  • vc/mfc
  • 嵌入式开发
  • 游戏开发
  • ios
  • 编程问答
  • 汇编语言
  • 微信小程序
  • 数据结构
  • OpenGL
  • 架构设计
  • qt
  • 微信公众号

最近更新的内容

    • 详谈Java编程之委托代理回调、内部类以及匿名内部类回调(闭包回调)
    • java 使用异常的好处总结
    • Spring Boot 使用Druid详解
    • java中hibernate二级缓存详解
    • java实现ftp文件上传下载功能
    • SpringBoot的服务注册与发现示例
    • Java编程实现从给定范围内随机N个不重复数生成随机数的方法小结
    • Spring核心IoC和AOP的理解
    • 详解Java从后台重定向(redirect)到另一个项目的方法
    • Java 归并排序算法、堆排序算法实例详解

关于我们 - 联系我们 - 免责声明 - 网站地图

©2020-2025 All Rights Reserved. linkedu.com 版权所有