操作系统实验一:进程和线程(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++是原子操作吗?


相关文章
|
3天前
|
算法 大数据 Linux
深入理解操作系统:进程管理与调度策略
【5月更文挑战第17天】 在现代计算机系统中,操作系统扮演着至关重要的角色。它不仅负责管理硬件资源,还为应用程序提供了一个执行环境。其中,进程管理是操作系统的核心功能之一,它涉及进程的创建、执行、暂停、终止以及调度等多个方面。本文将深入探讨操作系统中的进程管理机制,特别是进程调度策略,以期提供一个全面的视角来理解如何提高系统效率和响应速度。通过分析不同的调度算法,我们将讨论各自的优势、局限性以及适用场景,并探讨未来可能的发展趋势。
|
3天前
|
机器学习/深度学习 人工智能 算法
深入理解操作系统之进程调度策略
【5月更文挑战第17天】 在多任务操作系统中,进程调度策略是核心组成部分,其负责决定哪些可运行的进程将获得CPU时间以及持续多长时间。本文旨在探讨现代操作系统中实现的几种主要进程调度策略,包括先来先服务(FCFS)、短作业优先(SJF)、轮转(RR)和多级反馈队列(MLFQ)。通过分析每种策略的工作原理、优势与局限性,本文将提供一个全面的视角,帮助读者理解操作系统如何管理并发执行的任务,以及这些调度策略对系统性能的影响。同时,文章还将讨论未来调度策略的潜在发展趋势及其对操作系统设计的可能挑战。
|
2天前
|
监控 并行计算 算法
深入理解操作系统:进程管理与调度策略
【5月更文挑战第18天】 操作系统的核心职能之一是确保系统资源的高效管理和分配,其中进程管理作为其基石,直接影响着系统性能和响应速度。本文将详细探讨操作系统中的进程概念、进程状态转换以及进程调度策略,旨在为读者提供一个清晰的进程管理框架视图,并分析不同调度算法对系统行为的具体影响。通过比较各种调度策略,本文揭示了在不同应用场景下选择合适调度算法的重要性,同时指出了未来进程调度可能面临的挑战和发展方向。
|
3天前
|
算法 调度
深入理解操作系统中的进程调度策略
【5月更文挑战第18天】 在现代操作系统中,进程调度策略是决定系统性能和响应速度的关键要素。本文将探讨几种常见的进程调度算法,包括先来先服务(FCFS)、短作业优先(SJF)、轮转(Round Robin)以及多级反馈队列(Multilevel Feedback Queue),并分析它们的工作原理、优势和局限性。通过比较这些调度策略在不同应用场景下的表现,我们可以得出没有一种通用的最佳调度策略,而是根据具体需求选择最合适的方法。
10 3
|
3天前
|
算法 调度 数据中心
深入理解操作系统中的进程调度策略
【5月更文挑战第17天】 在现代操作系统中,进程调度是核心功能之一,它直接关系到系统性能和用户体验。本文将详细探讨几种常见的进程调度策略,包括先来先服务、短作业优先、轮转调度以及多级反馈队列等。通过比较它们的优缺点和适用场景,提供一个全面的视角来理解操作系统如何管理众多竞争资源的进程。此外,文章还将讨论现代操作系统中实现进程调度的复杂性,如实时性要求、多核处理和能源效率问题。
|
3天前
|
算法 Linux 调度
深入理解操作系统的进程调度策略
【5月更文挑战第17天】 在多任务操作系统中,进程调度策略是决定系统性能和效率的关键因素之一。本文将探讨操作系统中的几种主要进程调度算法,包括先来先服务(FCFS)、短作业优先(SJF)、轮转(Round Robin)以及多级反馈队列(Multilevel Feedback Queue),分析它们的原理、优缺点及适用场景。通过比较不同环境下的性能表现,本文旨在为读者提供一个关于如何选择合适调度策略的参考视角,并讨论现代操作系统如何结合这些策略以适应复杂多变的任务负载。
|
4天前
|
Java 测试技术 Python
Python的多线程允许在同一进程中并发执行任务
【5月更文挑战第17天】Python的多线程允许在同一进程中并发执行任务。示例1展示了创建5个线程打印&quot;Hello World&quot;,每个线程调用同一函数并使用`join()`等待所有线程完成。示例2使用`ThreadPoolExecutor`下载网页,创建线程池处理多个URL,打印出每个网页的大小。Python多线程还可用于线程间通信和同步,如使用Queue和Lock。
17 1
|
4天前
|
缓存 算法 Java
操作系统(8)---进程的同步与互斥以及信号量机制(万字总结~)(4)
操作系统(8)---进程的同步与互斥以及信号量机制(万字总结~)
19 0
|
5天前
|
存储 Linux Shell
Linux:进程等待 & 进程替换
Linux:进程等待 & 进程替换
30 9
|
5天前
|
存储 Linux C语言
Linux:进程创建 & 进程终止
Linux:进程创建 & 进程终止
28 6