24/12/15 learning~~

mohyeah · mohyeah · commit 840278667634 · 2024-12-15T15:34:22.000+08:00
diff --git a/AI Learn/Stage 2 Python Advanced/Chapter 1 Python Advanced Programing/11 1-11 线程/使用多线程完成多任务(带参数).py b/AI Learn/Stage 2 Python Advanced/Chapter 1 Python Advanced Programing/11 1-11 线程/使用多线程完成多任务(带参数).py
@@ -0,0 +1,30 @@
+# 多线程间执行是无序的，但是可以保证执行顺序
+
+import threading
+import time
+
+def music(times, content):
+    for i in range(times):
+        print(content)
+        time.sleep(0.2)
+
+def coding(times, content):
+    for i in range(times):
+        print(content)
+        time.sleep(0.2)
+
+if __name__ == '__main__':
+    t1 = threading.Thread(target=music, args=(5, "listening music"))
+    t2 = threading.Thread(target=coding, kwargs={"times": 5, "content": "coding"})
+
+    t1.start()
+    t2.start()
+
+    # 设置守护线程
+    # t1.threading.Tread(target=music, args=(5, "listening music"), daemon=True)
+    # 设置守护主线程
+    # threading.setDaemon(True)
+    # 等待两个线程执行完毕
+    t1.join()
+    t2.join()
+    print("end of the progress")
diff --git a/AI Learn/Stage 2 Python Advanced/Chapter 1 Python Advanced Programing/11 1-11 线程/使用多线程完成多任务.py b/AI Learn/Stage 2 Python Advanced/Chapter 1 Python Advanced Programing/11 1-11 线程/使用多线程完成多任务.py
@@ -0,0 +1,21 @@
+# 1. 导入模块
+import threading
+import time
+
+def music():
+    for i in range(10):
+        print("listening music")
+        time.sleep(0.2)
+
+def coding():
+    for i in range(10):
+        print("coding")
+        time.sleep(0.2)
+
+if __name__ == '__main__':
+    # 2. 创建线程对象
+    music_thread = threading.Thread(target=music)
+    coding_thread = threading.Thread(target=coding)
+    # 3. 启动线程 (两者交替执行)
+    music_thread.start()
+    coding_thread.start()
diff --git a/AI Learn/Stage 2 Python Advanced/Chapter 1 Python Advanced Programing/11 1-11 线程/线程间共享全局变量.py b/AI Learn/Stage 2 Python Advanced/Chapter 1 Python Advanced Programing/11 1-11 线程/线程间共享全局变量.py
@@ -0,0 +1,25 @@
+import threading
+import time
+
+my_list = []
+
+def add_to_list():
+    for i in range(3):
+        my_list.append(i)
+        print("add:",i)
+
+def read_from_list():
+    print(my_list)
+
+if __name__ == '__main__':
+    t1 = threading.Thread(target=add_to_list)
+    t2 = threading.Thread(target=read_from_list)
+
+    # 共享进程内的资源
+    t1.start()
+    t2.start()
+
+    t1.join()
+    t2.join()
+
+    print("the end of progress")
diff --git a/AI Learn/Stage 2 Python Advanced/Chapter 1 Python Advanced Programing/12 1-12 进程线程对比/多任务Web服务器开发.py b/AI Learn/Stage 2 Python Advanced/Chapter 1 Python Advanced Programing/12 1-12 进程线程对比/多任务Web服务器开发.py
@@ -0,0 +1,63 @@
+# 1. 导入socket模块
+import socket
+import threading
+
+# 6. 定义处理客户端请求的函数
+def handle_client_request(new_socket, ip_port):
+    # 7. 接收客户端发送的数据
+    recv_data = new_socket.recv(1024)
+    if recv_data:
+        recv_data = recv_data.decode('utf-8')
+        # 8. 获取用户请求的资源数据路径
+        request_path = recv_data.split(' ')[1]
+        if request_path == '/' or request_path == '/index.html':
+            request_path = 'index.html'
+        try:
+            with open(request_path, "rb") as file:
+                data = file.read()
+
+        except FileNotFoundError:
+            response_line = "HTTP/1.1 200 OK\r\n"
+            response_header = "Server:PWB2.0\r\nContent-type:text/html; charset=utf-8}\r\n"
+            response_body = "404 Not Found"
+
+            response_data = (response_line + response_header + "\r\n" + response_body).encode("utf-8")
+
+            new_socket.send(response_data)
+        else:
+            # 成功访问的文件
+            response_line = "HTTP/1.1 200 OK\r\n"
+            response_header = "Server: PWB2.0\r\n"
+            response_body = data
+
+            response_data = (response_line + response_header + "\r\n").encode("utf-8") + response_body
+            new_socket.send(response_data)
+
+        finally:
+            # 关闭套接字
+            new_socket.close()
+
+
+
+def main():
+    # 2. 创建套接字
+    server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+    # 设置端口复用
+    server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
+    # 3. 绑定ip和端口
+    server_socket.bind(("127.0.0.1", 9999))
+    # 4. 设置监听
+    server_socket.listen(128)
+    # 5. 等待客户端连接
+    while True:
+        new_socket, ip_port = server_socket.accept()
+        print("客户端{}已连接".format(ip_port))
+        # 创建子线程
+        sub_thread = threading.Thread(target=handle_client_request, args=(new_socket, ip_port))
+        # 启动子线程
+        sub_thread.start()
+
+
+
+if __name__ == '__main__':
+    main()
