18 11 16 网络通信 ---- 多线程 同步概念 解决资源互斥的问题

---恢复内容开始---

在多任务中  由于线程是分步执行  所以在很多线程执行的时候 会对全局变量造成很大的影响  如图中 线程一执行完一二步中 跳过第三部  而跑到线程二去执行 就会造成  全变量不稳定

引进   上锁 功能可以 不仅多线程 还能 把一个运行完再到下一个

import threading
import time

# 定义一个全局变量
g_num = 0

def test1(num):
    global g_num
    # 上锁,如果之前没有被上锁,那么此时 上锁成功
    # 如果上锁之前 已经被上锁了,那么此时会堵塞在这里,直到 这个锁被解开位置
    mutex.acquire()
    for i in range(num):
        g_num += 1
    # 解锁
    mutex.release()
    print("-----in test1 g_num=%d----" % g_num)

def test2(num):
    global g_num
    mutex.acquire()
    for i in range(num):
        g_num += 1
    mutex.release()
    print("-----in test2 g_num=%d=----" % g_num)

# 创建一个互斥锁,默认是没有上锁的
mutex = threading.Lock()

def main():
    t1 = threading.Thread(target=test1, args=(1000000,))
    t2 = threading.Thread(target=test2, args=(1000000,))

    t1.start()
    t2.start()

    # 等待上面的2个线程执行完毕....
    time.sleep(2)

    print("-----in main Thread g_num = %d---" % g_num)

if __name__ == "__main__":
    main()

编辑好的 软件跑网络助手报错  后面发现在网络调试助手里面  默认的IP地址  尽然是以  162  开头的

进入 cmd  通过命令 ipconfig/all

发现首选的才是  自己的正真ip地址

---恢复内容结束---

原文地址:https://www.cnblogs.com/fromlantianwei/p/9969858.html

时间: 2024-10-10 18:01:36

18 11 16 网络通信 ---- 多线程 同步概念 解决资源互斥的问题的相关文章

18 11 15 网络通信 ---- 多线程

下面是一个  多线程  运算  调用了 threading  模块   可以同时在一个程序中  跑两个函数 import threading def text1 (): for i in range(5): print("-----%d-----" % i) def text2 (): for i in range(5): print("-----%d-----" % i) def main(): t1 = threading.Thread(target=text1

18 11 12 网络通信 tcp

tec 客户端的接受代码 import socket def main(): # 1. 创建tcp的套接字 tcp_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) # 2. 链接服务器 # tcp_socket.connect(("192.168.33.11", 7890)) server_ip = input("请输入要链接的服务器的ip:") server_port = int(input(&

18 11 20 网络通信 ----多任务---- 携程 ----迭代器

进行多任务的学习    携程   开始做一个迭代器   再做生成器  再学习携程    迭代器就是  可以用 for 循环 表示的一个 class import time from collections import Iterable from collections import Iterator class Classmate(object): def __init__(self): self.names = list() self.current_num = 0 def add(self

18 11 20 网络通信 ----多任务---- 携程 ----生成器

---恢复内容开始--- 在一个函数里面  只要有yield  就是一个生成器    举一个例子  下面的是打印一个菲薄那数列 def creat_num (all_numbers): a, b = 0, 1 current_num = 0 while current_num <= all_numbers: current_num += 1 print(a) a , b = b ,a+b list1 = creat_num(10) 当把  print  改换成 yield的时候  就是一个生成器

Delphi多线程编程(10)--多线程同步之Mutex(互斥对象)

原理分析: 互斥对象是系统内核对象,各个线程都可以拥有它,谁拥有它谁就可以执行 执行完毕,用ReleaseMutex 函数释放拥有权,以让其他等待的线程可以使用 其他线程可以使用 WaitForSingleObject函数排队等待(等待也可以理解为排队申请) 使用过程 var hMutex: THandle; {应该先声明一个全局的互斥句柄} CreateMutex {建立互斥对象} WaitForSingleObject {用等待函数排队等候} ReleaseMutex {释放拥有权} Clo

读写锁(read-write lock)机制-----多线程同步问题的解决

读写锁(read-write lock)一 综述    在一些程序中存在读者写者问题,也就是说,对某些资源的访问会  存在两种可能的情况,一种是访问必须是排它行的,就是独占的意思,这称作写操作:另一种情况就是访问方式可以是共享的,就是说可以有多个线程同时去访问某个资源,这种就称作读操作.这个问题模型是从对文件的读写操作中引申出来的.    读写锁比起mutex具有更高的适用性,具有更高的并行性,可以有多个线程同时占用读模式的读写锁,但是只能有一个线程占用写模式的读写锁,读写锁的三种状态:1.当读

python多线程同步实例分析

进程之间通信与线程同步是一个历久弥新的话题,对编程稍有了解应该都知道,但是细说又说不清.一方面除了工作中可能用的比较少,另一方面就是这些概念牵涉到的东西比较多,而且相对较深.网络编程,服务端编程,并发应用等都会涉及到.其开发和调试过程都不直观.由于同步通信机制的原理都是想通的,本文希通过望借助python实例来将抽象概念具体化. 阅读之前可以参考之前的一篇文章:python多线程与多进程及其区别,了解一下线程和进程的创建. python多线程同步 python中提供两个标准库thread和thr

《使用 C++11 编写 Linux 多线程程序(转载收藏)》

转载自: http://www.ibm.com/developerworks/cn/linux/1412_zhupx_thread/ 本文讲述了如何使用 C++11 编写 Linux 下的多线程程序,如何使用锁,以及相关的注意事项,还简述了 C++11 引入的一些高级概念如 promise/future 等. 前言 在这个多核时代,如何充分利用每个 CPU 内核是一个绕不开的话题,从需要为成千上万的用户同时提供服务的服务端应用程序,到需要同时打开十几个页面,每个页面都有几十上百个链接的 web

Java并发编程之多线程同步

线程安全就是防止某个对象或者值在多个线程中被修改而导致的数据不一致问题,因此我们就需要通过同步机制保证在同一时刻只有一个线程能够访问到该对象或数据,修改数据完毕之后,再将最新数据同步到主存中,使得其他线程都能够得到这个最新数据.下面我们就来了解Java一些基本的同步机制. Java提供了一种稍弱的同步机制即volatile变量,用来确保将变量的更新操作通知到其他线程.当把变量声明为volatile类型后,编译器与运行时都会注意到这个变量是共享的.然而,在访问volatile变量时不会执行加锁操作