操作系统实验一:进程和线程(2)

简介: 七、共享资源的互斥访问创建两个线程来实现对一个数的递加 pthread_example.c1、运行

操作系统实验一:进程和线程(1):https://developer.aliyun.com/article/1407233

七、共享资源的互斥访问

创建两个线程来实现对一个数的递加 pthread_example.c

1、运行

例程1

代码太长,截图不便,我直接贴文本吧。

#include<pthread.h>
#include<stdlib.h>
#include<stdio.h>
#include<sys/time.h>
#include<string.h>
#include<unistd.h>
#define MAX 10
pthread_t thread[2];
pthread_mutex_t mut;
int number=0;
int i;
void thread1(){
  printf("thread1: I'm thread 1\n");
  for(i=0;i<MAX;i++){
    printf("thread1: number=%d\n",number);
    pthread_mutex_lock(&mut);
    number++;
    pthread_mutex_unlock(&mut);
    sleep(2);
  }
  pthread_exit(NULL);
}
void thread2(){
  printf("thread2: I'm thread 2\n");
  for(i=0;i<MAX;i++){
    printf("thread2: number=%d\n",number);
    pthread_mutex_lock(&mut);
    number++;
    pthread_mutex_unlock(&mut);
    sleep(3);
  }
  pthread_exit(NULL);
}
void thread_create(){
  int temp;
  memset(&thread,0,sizeof(thread));
  if( (temp=pthread_create(&thread[0],NULL,(void*)thread1,NULL)) != 0){
    printf("create thread1 failed!\n");
  }else{
    printf("create thread1 success!\n");
  }
  if( (temp=pthread_create(&thread[1],NULL,(void*)thread2,NULL)) != 0){
    printf("create thread2 failed!\n");
  }else{
    printf("create thread2 success!\n");
  }
}
void thread_wait(){
  if(thread[0]!=0){
    pthread_join(thread[0],NULL);
    printf("thread1 end!\n");
  }
  if(thread[1]!=0){
    pthread_join(thread[1],NULL);
    printf("thread2 end!\n");
  }                   
}
int main(){
  pthread_mutex_init(&mut,NULL);
  printf("I am main, I am creating thread!\n");
  thread_create();
  printf("I am main, I am waiting thread end!\n");
  thread_wait();
  return 0;
}

b05a70b0c8234176a386b66807c60af5.png

2、解释运行结果

进程是资源分配的基本单位,线程是调度的基本单位。上述代码中,int number和int i都是被两个线程所共享的变量。利用mutex可以实现对共享资源的互斥访问,这个比较容易理解,但是上面的运行结果中,可能有些令人疑惑的地方。


1、为什么会打印两次"number=0",这正常吗?


是正常的,比如在如下图所示的执行顺序(但不唯一)中,就会出现打印两次"number=0"然后打印"number=2"的情况。注意sleep()会直接让当前进程阻塞,因此下图中在sleep处都是拐点

e63dd231182b486ca4b93b0e1b8b71a5.png

2、为什么thread1连续输出了两个数"number=6"和"number=7"?


对进程的同步与互斥有些模糊时,容易产生这样的疑问。运行结果中,大部分输出都是thread1和thread2交替的,只有6和7这里是同一个线程连续输出两次,以至于觉得本应该交替输出、而连续输出是异常的。


其实不是,上述thread1的代码中是sleep(2),而thread2的代码中是sleep(3)。如果你将thread1中的sleep(2)修改成sleep(1),可以观察到大部分时候都是thread1在连续输出。总之,代码中只是使用mutex实现了对共享资源的互斥访问而已,并没有实现同步。


3、验证lock与unlock的作用。


到这里,我只知道mutex可以实现对共享资源(全局变量number)的互斥访问,程序也确实看起来正常运行。不过,它只循环了10次呢。而且不知道你有没有发现一个问题,另一个全局变量i,不也同样是thread1和thread2两个线程的共享资源吗?


让我们将总循环次数提到10万吧:#define MAX=100000,同时将阻塞时间缩到sleep(0.001)让它运行得快一点。然后重新编译并运行一下我们的代码:


例程2:

0bbadb1cbe7d4a4da896640015c53bbd.png

看!最后结果是number=100018,而并不是我们所设置的100000,那么很可能就是由于对于共享变量 i 的访问发生了冲突。我将例程2运行了5次,记录每次最后的number值如下:

100018 100017 100011 100024 100009

为了验证确实是变量 i 导致的问题,而不是其它的什么原因——比如上帝在你的计算机里边掷骰子,我们不妨给 i 也加上互斥。

例程3

我新增了一个新的用于互斥的变量mut_i,并在两个线程函数的循环中都改用lockunlock来保护记录循环迭代的i++语句。

e56659870ad249049c78106dc1855971.png

6c9a68e1c3504c6ba8131f67f1d89843.png

我同样将这个修改后的例程3运行了5次,其中有四次是正确的结果number=100000。可很遗憾,我也不知道在第一次运行中为什么会出现连续两个number=99999,不过我觉得这不一定是资源互斥中所导致的问题。


总之,凡有赋值的操作在多线程环境都要加锁,不论是上述的number++,还是i++。因为,它们都不是原子操作,从机器指令的层面来看,一个高级语言中的i++包含多个步骤,而一条语句还没执行完,可能就已经发生中断,转而去执行另一个线程了。


4、在例程2和例程3的执行结果中,每次最终的number值都是偏大,为什么不会偏小呢?


例程4:


下面我解除了对于变量 number 的互斥保护,而保持对 i 的互斥保护。

fb1d76562e414d0d965e55bc7b669563.png

6ec90ec559fe4390a4cac352832db5e0.png

可以看到我连续运行五次结果中,number 每次都是比10万要偏小。这个具体的细节,其实回忆一下以前数据库并发控制中丢失修改导致的数据不一致问题,就明白了,情况如下图所示。而当 i 偏小的时候,i 的递增次数就小于实际迭代次数,于是导致了 number 的结果偏大。

21055adac1c242b1b53e2c767a6394b6.png

参考

  1. https://blog.csdn.net/JMW1407/article/details/108318960 - int i =1 是原子操作吗?i++是原子操作吗?


相关文章
|
19天前
|
安全 Java 数据处理
Python网络编程基础(Socket编程)多线程/多进程服务器编程
【4月更文挑战第11天】在网络编程中,随着客户端数量的增加,服务器的处理能力成为了一个重要的考量因素。为了处理多个客户端的并发请求,我们通常需要采用多线程或多进程的方式。在本章中,我们将探讨多线程/多进程服务器编程的概念,并通过一个多线程服务器的示例来演示其实现。
|
2月前
|
资源调度 监控 算法
深入理解操作系统:进程管理与调度策略
本文旨在探讨操作系统中进程管理的核心概念及其实现机制,特别是进程调度策略对系统性能的影响。通过分析不同类型操作系统的进程调度算法,我们能够了解这些策略如何平衡响应时间、吞吐量和公平性等关键指标。文章首先介绍进程的基本概念和状态转换,随后深入讨论各种调度策略,如先来先服务(FCFS)、短作业优先(SJF)、轮转(RR)以及多级反馈队列(MLQ)。最后,文章将评估现代操作系统在面对多核处理器和虚拟化技术时,进程调度策略的创新趋势。
|
2天前
|
算法 调度 UED
深入理解操作系统中的进程调度策略
【4月更文挑战第28天】 在多任务操作系统中,进程调度策略是决定系统性能和响应能力的关键因素。本文将探讨操作系统中进程调度的基本原理、不同调度算法的特点及其适用场景,并通过分析比较它们的优缺点,提供一个全面的视角来理解操作系统如何管理运行中的进程。通过深入了解这些调度策略,读者可以更好地把握操作系统的行为模式,以及如何在特定应用中选择合适的调度策略以优化系统表现。
|
5天前
|
算法 Linux 调度
深入理解操作系统中的进程调度策略
【4月更文挑战第25天】 在多任务操作系统中,进程调度策略是核心组件之一,它负责决定哪个可运行的进程将获得CPU时间。本文将探讨不同的进程调度算法,包括它们的原理、优缺点以及适用场景。我们将重点分析先到先服务(FCFS)、短作业优先(SJF)、轮转调度(RR)和多级反馈队列(MLFQ)等经典算法,并讨论现代操作系统如Linux和Windows中的实际调度策略。文章的目的是为读者提供对操作系统进程调度机制深度了解,并展示其在系统性能和用户体验中的关键作用。
|
5天前
|
负载均衡 算法 调度
深入理解操作系统中的进程调度策略
【4月更文挑战第25天】 在现代操作系统的核心功能中,进程调度策略扮演着至关重要的角色。本文将详细解析进程调度的基本概念、调度算法的种类及其背后的原理,并探讨它们对系统性能的影响。通过比较不同的调度策略,我们可以更深入地理解操作系统如何管理资源,确保多任务环境下的效率和公平性。
|
6天前
|
Java 数据库连接 数据处理
Python从入门到精通:3.1.2多线程与多进程编程
Python从入门到精通:3.1.2多线程与多进程编程
|
13天前
|
调度 Python
Python多线程、多进程与协程面试题解析
【4月更文挑战第14天】Python并发编程涉及多线程、多进程和协程。面试中,对这些概念的理解和应用是评估候选人的重要标准。本文介绍了它们的基础知识、常见问题和应对策略。多线程在同一进程中并发执行,多进程通过进程间通信实现并发,协程则使用`asyncio`进行轻量级线程控制。面试常遇到的问题包括并发并行混淆、GIL影响多线程性能、进程间通信不当和协程异步IO理解不清。要掌握并发模型,需明确其适用场景,理解GIL、进程间通信和协程调度机制。
29 0
|
22天前
|
算法 Linux 调度
深入理解操作系统的进程调度策略
【4月更文挑战第8天】本文深入剖析了操作系统中的关键组成部分——进程调度策略。首先,我们定义了进程调度并解释了其在资源分配和系统性能中的作用。接着,探讨了几种经典的调度算法,包括先来先服务(FCFS)、短作业优先(SJF)以及多级反馈队列(MLQ)。通过比较这些算法的优缺点,本文揭示了它们在现实世界操作系统中的应用与局限性。最后,文章指出了未来进程调度策略可能的发展方向,特别是针对多核处理器和云计算环境的适应性。
|
23天前
|
算法 调度 UED
深入理解操作系统中的进程调度策略
【4月更文挑战第7天】 在多任务操作系统中,进程调度策略是决定系统性能和响应速度的关键因素之一。本文将探讨现代操作系统中常用的进程调度算法,包括先来先服务、短作业优先、轮转调度以及多级反馈队列等。通过比较各自的优势与局限性,我们旨在为读者提供一个全面的视角,以理解如何根据不同场景选择合适的调度策略,从而优化系统资源分配和提升用户体验。
|
28天前
|
安全 Linux API
Android进程与线程
Android进程与线程
20 0