并发编程-单元练习题

中断是指在计算机执行期间，系统内发生任何非寻常的或非预期的急需处理事件，使得cpu暂时中断当前正在执行的程序，
转去执行相应的事件处理程序。待处理完毕后又返回原来被中断处继续执行或调度新的进程执行的过程。
它使计算机可以更好更快利用有限的系统资源解决系统响应速度和运行效率的一种控制技术。
实时响应，系统调度。

内核态：cpu可以访问内存的所有数据，包括外围设备，例如硬盘，网卡，cpu也可以将自己从一个程序切换到另一个程序。
用户态：只能受限的访问内存，且不允许访问外围设备，占用cpu的能力被剥夺，cpu资源可以被其他程序获取。
为什么要有用户态和内核态？
    由于需要限制不同的程序之间的访问能力，防止他们获取别的程序的内存数据，或者获取外围设备的数据，并发送到网络，
    cpu划分出两个权限等级：用户态和内核态。

进程指：正在执行的一个程序或者说一个任务，负责执行任务的是cpu。进程是用来把资源集中到一起的，进程是资源单位，或者说资源集合。

进程间通信(IPC)

管道通常指无名管道
1、它是半双工的（即数据只能在一个方向上流动），具有固定的读端和写端
2、它只能用于具有亲缘关系的进程中通信（也就是父与子进程或者兄弟进程之间）
3、数据不可反复读取了，即读了之后欢喜红区中就没有了
消息队列
1、消息队列是面向记录的，其中的消息具有特定的格式以及特定的优先级
2、消息队列独立于发送与接收进程。进程终止时，消息队列及其内容不会被删除。
3、消息队列可以实现消息随机查询。
 
    队列 = 管道 + 锁

队列，信号量(Semaphore),Event事件，定时器Timer,线程queue,进程池和线程池，异步调用+回调机制

同步I/O操作：实际的I/O操作将导致请求进程阻塞，直到I/O操作完成。

异步I/O操作：实际的I/O操作不导致请求进程阻塞。

同步或者异步I/O主要是指访问数据的机制(即实际I/O操作的完成方式)，

同步 一般指主动请求并等待I/O操作完毕的方式，I/O操作未完成前，会导致应用进程挂起；

而异步 指用户进程触发IO操作以后便开始做自己的事情，而当IO操作已经完成的时候会得到IO

完成的通知（异步的特点就是通知）,这可以使进程在数据读写时也不阻塞。

python 多进程通信Queue Pipe Value Array
queue和pipe用来在进程间传递消息;
Value + Array 是python中共享内存映射文件的方法;速度比较快.

Python multiprocessing.Manager（进程间共享数据）
Python中进程间共享数据，除了基本的queue，pipe和value+array外，还提供了更高层次的封装。使用multiprocessing.Manager可以简单地使用这些高级接口。
Manager支持的类型有list,dict,Namespace,Lock,RLock,Semaphore,BoundedSemaphore,Condition,Event,Queue,Value和Array。

from threading import Thread,currentThread
import datetime,time
def print_time():
    time_now = datetime.datetime.now()
    print(currentThread().getName(),time_now)
if __name__ == ‘__main__‘:
    time.sleep(10)
    for i in range(10):
        t = Thread(target=print_time)
        t.start()

Thread-1 2018-10-03 17:46:20.225000
Thread-2 2018-10-03 17:46:20.226000
Thread-3 2018-10-03 17:46:20.227000
Thread-4 2018-10-03 17:46:20.227000
Thread-5 2018-10-03 17:46:20.228000
Thread-6 2018-10-03 17:46:20.229000
Thread-7 2018-10-03 17:46:20.229000
Thread-8 2018-10-03 17:46:20.230000
Thread-9 2018-10-03 17:46:20.230000
Thread-10 2018-10-03 17:46:20.231000

服务端：
import socketserver
class Handler(socketserver.BaseRequestHandler):
    def handle(self):
        print(‘new connection:‘, self.client_address)
        while True:
            try:
                data = self.request.recv(1024)
                if not data: break
                print(‘client data:‘, data.decode())
                self.request.send(data.upper())
            except Exception as e:
                print(e)
                break


if __name__ == "__main__":
    server = socketserver.ThreadingTCPServer((‘127.0.0.1‘, 8082), Handler)
    server.serve_forever()

客户端
模拟多个线程 ---客户端发送消息

 def start(ip_port):
    client = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
    client.connect(ip_port)
    client.send(f"{currentThread().getName()} hello".encode(‘utf-8‘))
    data = client.recv(1024)
    print(data.decode(‘utf-8‘))

if __name__ == ‘__main__‘:
    import socket
    from threading import Thread,currentThread
    ip_port = (‘127.0.0.1‘,8082)
    for i in range(20):
        t = Thread(target=start,args=(ip_port,))
        t.start()