并发编程模型

并发编程模型

一.分类

按照线程通信机制可以分为共享内存模型消息传递模型

1.共享内存模型:线程之间共享程序的公共状态,编程之间通过读写内存中的公共状态来隐式进行通信。相互通信的进程共享某些数据结构或共享存储区,进程通过这些空间进行通信,因此又可以分为两种类型:

1).基于共享数据结构的通信方式。在这种通信方式中要求各进程公用某些数据结构来实现进程间的信息交换。比如用有界缓冲区这种数据结构实现生产者-消费者问题。在这里公用数据结构的设置和进程间同步的处理,会增加负担,所以这种通信方式是低微的,只适用于传递相对少量的数据。

2).基于共享存储区的通信方式。为了大量传输数据,在存储器中划分出了一块共享存储区;各个进程可以通过对数据的读或写来实现通信。这种方式下,进程在通信前,先向系统申请获得共享存储区的一个分区并指定该分区的关键字;若系统已经给其他进程分配了这样的分区,则返回该分区的描述符,申请者将获得的共享存储分区连接到本进程上,然后就可以像读写普通存储器一样地读写公共存储分区。

2.消息传递模型:线程之间没有公共状态,线程之间必须通过明确的发送消息来显示进行通信,当任务在不同的计算机上运行时通常使用。 当任务需要与另一个进行通信时,它会发送遵循预定义协议的消息。 如果发送方在发送消息后继续执行,发送方被阻塞等待响应或异步,则该通信可以是同步的。消息系统的功能是允许进程与其它的进程进行通信。我们已经看到了消息传递在微内核中的应用。在这种方案下,服务作为普通的用户进程提供,服务在内核之外。用户进程之间的通信通过传递消息完成。IPC 至少提供了两种操作:send和receive。 进程发送的消息可以是定长的也可以是变长的。如果只可以发送定长的消息,那么系统层的实现就很简单。然而,这种限制增加了 程序设计的难度。另一方面,变长的消息需要更复杂的系统层实现,但是 程序设计工作更简单

如果进程P 和Q要进行通信,那么它们必须能够互相发送和接收消息;二者之间必须要建立一条通信链路。有多种方法可以实现这条链路。在这儿,我们并不关心链路的物理实现,而是要考虑它的逻辑实现。有如下几种用于逻辑实现send/receive 操作的方法:

  1. 直接或间接通信

  2. 对称或不对称通信

  3. 自动或手动缓冲

  4. 发送拷贝或引用

  5. 定长消息或变长消息

同步是指程序用于控制不同线程之间操作发生相对顺序的机制。在共享内存并发模 型里,同步是显式进行的。程序员必须显式指定某个方法或某段代码需要在线程之 间互斥执行。在消息传递的并发模型里,由于消息的发送必须在消息的接收之前, 因此同步是隐式进行的。

实现同步的机制主要有临界区、互斥、信号量和事件

临界区:通过对多线程的串行化来访问公共资源或一段代码,速度快,适合控制数据访问。在任意时刻只允许一个线程对共享资源进行访问,如果有多个线程试图访问公共资 源,那么在有一个线程进入后,其他试图访问公共资源的线程将被挂起,并一直等到进入临界区的线程离开,临界区在被释放后,其他线程才可以抢占。

互斥量:采用互斥对象机制。 只有拥有互斥对象的线程才有访问公共资源的权限,因为互斥对象只有一个,所以能保证公共资源不会同时被多个线程访问。互斥不仅能实现同一应用程序的公共资源安全共享,还能实现不同应用程序的公共资源安全共享 .互斥量比临界区复杂。因为使用互斥不仅仅能够在同一应用程序不同线程中实现资源的安全共享,而且可以在不同应用程序的线程之间实现对资源的安全共享。

信号量:它允许多个线程在同一时刻访问同一资源,但是需要限制在同一时刻访问此资源的最大线程数目 。信号量对象对线程的同步方式与前面几种方法不同,信号允许多个线程同时使用共享资源,这与操作系统中的PV操作相同。它指出了同时访问共享资源的线程最大数目。它允许多个线程在同一时刻访问同一资源,但是需要限制在同一时刻访问此资源的最大线程数目。

事件:通过通知操作的方式来保持线程的同步,还可以方便实现对多个线程的优先级比较的操作 。

:Java 的并发采用的是共享内存模型,Java 线程之间的通信总是隐式进行,整个通 信过程对程序员完全透明。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/448909.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

换工作,让我里外不是人,到底错在哪儿

看看时间,现在是凌晨4点多,窗外时不时一道闪电,雨也一阵一阵的,雷声像逐渐远离的喧嚣的火车一样。我不是睡眠困难者,但是,昨晚吃完晚饭之后,在衣服都未脱的情况下,晕晕乎乎的睡到现在…

Flink Kafka consumer的消费策略配置

val helloStream: FlinkKafkaConsumer011[String] new FlinkKafkaConsumer011[String]("hello", valueDeserializer, kafkaProps) // 指定消费策略 helloStream.setStartFromEarliest() // - 从最早的记录开始; helloStream.setStartFromLatest() //…

spdk/dpdk 编译相关问题汇总

下载 到官网上下载最新的spdk 代码。 解决编译依赖 yum install libaio.x86_64 libaio-devel.x86_64 编译dpdk 特别注意的是dpdk:依赖 /lib/modules/uname -a/build 下执行的内核已经存在,并且编译过,为此需要: 下载内核;安装依赖…

深入浅出 消息队列 ActiveMQ

前些天发现了一个巨牛的人工智能学习网站,通俗易懂,风趣幽默,忍不住分享一下给大家。点击跳转到教程。 一、 概述与介绍 ActiveMQ 是Apache出品,最流行的、功能强大的即时通讯和集成模式的开源服务器。ActiveMQ 是一个完全支持JM…

2018-2019 ACM-ICPC Nordic Collegiate Programming Contest (NCPC 2018) - 4.28

赛后补了几道 赛中我就写了两个... A - Altruistic AmphibiansGym - 101933A 看了眼榜没几个人做。就没看。 最后发现就是一个DP(但是我觉得复杂度有点迷) 题意:$n$只青蛙有参数$l,w,h$分别表示弹跳力,体重,身高&#…

消息队列技术介绍 : ActiveMQ、RabbitMQ、ZeroMQ、Kafka、MetaMQ、RocketMQ

一、 消息队列概述 前些天发现了一个巨牛的人工智能学习网站,通俗易懂,风趣幽默,忍不住分享一下给大家。点击跳转到教程。 消息队列中间件是分布式系统中重要的组件,主要解决应用耦合、异步消息、流量削锋等问题。实现高性能、高可…

程序员的恶性循环 !

穷人的恶性循环: 穷 -> 需要努力工作 -> 没有时间去交际 -> 人脉越来越狭窄 -> 工作越来越难做 -> 越需要努力去工作 -> 越没有时间去发展人脉 -> 越穷 富人的良性循环: 有钱 -> 工作很轻松 -> 很多时间都在交际上 -> 人…

刷脸考勤,重新定位校园管理

近几年,人脸识别技术在安防领域得到了广泛应用,随着技术的不断发展,它离我们的日常生活越来越近,手机、商场、公园、校园等都可以看到它的身影。刷脸考勤,重新定义校园管理。人脸识别,也叫面部识别&#xf…

python爬虫学习之页面登陆

爬虫学习的一点心得 登陆主要有3种方法:使用selenium,cookies,模拟表单登陆 个人对于一般情况使用cookies登陆 可以实现一次手动,长期自动,可以绕过登陆(登陆的相关信息密码,账号等会存于cookie…

消息队列 应用场景 解析

前些天发现了一个巨牛的人工智能学习网站,通俗易懂,风趣幽默,忍不住分享一下给大家。点击跳转到教程。 另外腾讯云-云社区还有一文不允许转载,但内容挺好的:https://cloud.tencent.com/developer/article/1006035 分布…

求职面试的时候如何谈薪酬待遇

在社会大学里混了那么多年,我最惨痛的经历就是,在应聘一家企业的时候,总是羞于谈薪酬待遇。大概这是很多职场新人都会遇到过的尴尬吧——觉得自己经验不够,或者想应聘的企业比较好,就觉得对方提多少就是多少吧&#xf…

利用memcached实现CAS单点登录集群部署

前言:利用memcached实现CAS单点登录集群部署 负载均衡:将接口请求的有状态性变成无状态性。是我们在实现负载均衡时必要要解决的问题。以应用接口的session状态为例,一般解决方法都是将session数据和应用进行剥离,session数据统一…

注册

<!DOCTYPE html><html lang"en"><head> <meta charset"UTF-8"> <title>注册</title> {# 导入jQuery基础类库&#xff0c;才可以使用 $ #} <script src"../static/js/jquery-1.12.4.min.js"&…

Linux中10个有用的命令行补齐命令

本文由 极客范 - 踏雁寻花 翻译自 Balakrishnan Mariyappan。欢迎加入极客翻译小组&#xff0c;同我们一道翻译与分享。转载请参见文章末尾处的要求。在Linux系统中&#xff0c;输入一个命令&#xff0c;再按两次TAB键&#xff0c;就会列出所有以输入字符开头的可用命令。这并…

分布式开放消息系统 ( RocketMQ ) 的原理与实践

分布式消息系统作为实现分布式系统可扩展、可伸缩性的关键组件&#xff0c;需要具有高吞吐量、高可用等特点。而谈到消息系统的设计&#xff0c;就回避不了两个问题&#xff1a; 消息的顺序问题消息的重复问题RocketMQ作为阿里开源的一款高性能、高吞吐量的消息中间件&#xff…

数据结构02-链表

说明&#xff1a;由于该数据结构是由java并且是原生实现&#xff0c;所以与C有一些出入&#xff0c;不过原理是相同的 1.链表的定义 为了表示线性表元素a与a1的逻辑关系&#xff0c;存储数据时&#xff0c;除了存储元素本身的信息之外&#xff0c;还存储了直接后继元素的位置信…

第四章 面向对象

第四章 面向对象 1. 基本格式 定义&#xff1a;当函数(业务功能)比较多&#xff0c;可以使用面向对象来进行归类&#xff0c;如果有一个凡事使用的公共值&#xff0c;也可以放到对象中 #格式&关键字 class 类名:def __inti__(self,x)self.x xdef 方法名(self,name):print(…

洛谷P2347 砝码称重 某一年noip提高组原题

可以转化为01背包求方案数的问题&#xff0c;dp数组f[][]表示第几个砝码能称出的重量,可压缩至一维 转移方程为f(i,j)f(i-1,j-w[i]) 当前我们可以称出的重量必定是由之前的砝码重量转移过来的 #include<bits/stdc.h> using namespace std; const int N550; const int max…

解决:-bash: unzip: command not found (Linux 中 unZip/Zip 的安装及使用)

前些天发现了一个巨牛的人工智能学习网站&#xff0c;通俗易懂&#xff0c;风趣幽默&#xff0c;忍不住分享一下给大家。点击跳转到教程。 Linux系统没有自带的压缩解压工具&#xff1b;需要我们自己安装&#xff1b; 当用到zip或者unzip如果没有安装就会出现 unzip: Command…

云计算时代IT专业人员需具备的10项技能

摘要&#xff1a;IT专业人员需要不断的学习&#xff0c;才能确保自己的工作能力跟上时代的步伐。云时代IT专业人员不仅需要具备一定的专业技能&#xff0c;比如快速运用自身知识快速在互联网上构建应用程序&#xff0c;还必须具备商业、金融、业务需求分析等等。 【编者按】谈…