24/12/14 learning~~

mohyeah · mohyeah · commit 09c0378443f6 · 2024-12-14T21:54:05.000+08:00
diff --git a/AI Learn/Stage 2 Python Advanced/Chapter 1 Python Advanced Programing/10 1-10 进程/Python中使用多进程完成多任务(带参数).py b/AI Learn/Stage 2 Python Advanced/Chapter 1 Python Advanced Programing/10 1-10 进程/Python中使用多进程完成多任务(带参数).py
@@ -0,0 +1,31 @@
+# 创建进程:
+# 1. 导入进程模块
+import multiprocess
+import time
+
+def music(times, t):
+    for i in range(times):
+        print("listening music")
+        time.sleep(t)
+
+def coding(t):
+    for i in range(3):
+        print("coding")
+        time.sleep(t)
+
+def main():
+    # 2. 创建子进程
+    p1 = multiprocess.Process(target=music, args=(3,0.2))  # 元组方式传参, 要和参数顺序保持一致
+    p2 = multiprocess.Process(target=coding, kwargs={'t': 0.2}) # 字典方式传参, key和参数名保持一致
+
+    # 3. 启动进程
+    p1.start()
+    p2.start()
+    # 4. 等待进程执行完毕
+    p1.join()
+    p2.join()
+
+    print("主进程结束")
+
+if __name__ == '__main__':
+    main()
diff --git a/AI Learn/Stage 2 Python Advanced/Chapter 1 Python Advanced Programing/10 1-10 进程/Python中使用多进程完成多任务.py b/AI Learn/Stage 2 Python Advanced/Chapter 1 Python Advanced Programing/10 1-10 进程/Python中使用多进程完成多任务.py
@@ -0,0 +1,37 @@
+# 多任务: 并发, 并行
+# 并发: 多个任务同时执行(一段时间内交替进行)
+# 并行: 多个任务同时执行(一段时间内同时进行, 任务数<CPU数)
+# 进程: 运行一个程序的一个实例, 系统进行资源分配的基本单位, 进程一个进程可以有多个线程
+# 线程: 同一个进程内的资源分配的最小单位
+
+# 创建进程:
+# 1. 导入进程模块
+import multiprocess
+import time
+
+def music():
+    for i in range(3):
+        print("listening music")
+        time.sleep(0.2)
+
+def coding():
+    for i in range(3):
+        print("coding")
+        time.sleep(0.2)
+
+def main():
+    # 2. 创建子进程
+    p1 = multiprocess.Process(target=music)
+    p2 = multiprocess.Process(target=coding)
+
+    # 3. 启动进程
+    p1.start()
+    p2.start()
+    # 4. 等待进程执行完毕
+    p1.join()
+    p2.join()
+
+    print("the end")
+
+if __name__ == '__main__':
+    main()
diff --git a/AI Learn/Stage 2 Python Advanced/Chapter 1 Python Advanced Programing/10 1-10 进程/使用Python杀进程.py b/AI Learn/Stage 2 Python Advanced/Chapter 1 Python Advanced Programing/10 1-10 进程/使用Python杀进程.py
@@ -0,0 +1,7 @@
+import os
+
+pid = eval(input("请输入进程编号: "))
+os.kill(pid, 9) # pid 进程编号
+                       # signal 信号, 与操作系统有关, 9为强制杀死进程, 15为正常结束进程
+
+print("进程:{} is killed".format(pid))
diff --git a/AI Learn/Stage 2 Python Advanced/Chapter 1 Python Advanced Programing/10 1-10 进程/获取进程编号.py b/AI Learn/Stage 2 Python Advanced/Chapter 1 Python Advanced Programing/10 1-10 进程/获取进程编号.py
@@ -0,0 +1,31 @@
+import os
+import multiprocessing
+import time
+
+# 获取当前进程编号
+
+def work():
+    print("executing the work")
+
+    # 方法1: os.getpid()
+
+    pid = os.getpid()    # 获取当前进程编号
+    print("work子进程编号:{}".format(pid))
+
+    ppid = os.getppid()    # 获取父进程编号
+    print("当前进程父进程编号:{}".format(ppid))
+    time.sleep(20)
+
+if __name__ == '__main__':
+    print("主进程编号:{}".format(os.getpid()))
+    sub_process = multiprocessing.Process(target=work)
+    sub_process.start()
+
+
+
+'''
+#方法2: multiprocess.current_process()
+pid = multiprocessing.current_process().pid
+print(pid)
+time.sleep(29)
+'''
diff --git a/AI Learn/Stage 2 Python Advanced/Chapter 1 Python Advanced Programing/10 1-10 进程/进程的注意点.py b/AI Learn/Stage 2 Python Advanced/Chapter 1 Python Advanced Programing/10 1-10 进程/进程的注意点.py
@@ -0,0 +1,42 @@
+# 1. 进程间独立, 全局变量不互通 (父进程和子进程是独立的, 但是主进程中的全局变量是共享的)
+# 2. 主进程默认不会等待子进程结束再结束, 当主进程直接结束, 子进程可能还在执行
+
+import multiprocessing
+
+# 创建一个全局变量(主进程中的全局变量)(主进程中的资源)
+my_list = []
+
+def write_data():
+    for i in range(3):
+        my_list.append(i)
+        print("add:",i)
+    print("write_data:{}".format(my_list))
+
+def read_data():
+    print("read_data:{}".format(my_list))
+
+def main():
+    p1 = multiprocessing.Process(target=write_data) # 创建子进程, copy一份主进程中的资源
+                                                    # 对自己进程中的资源进行操作
+    p2 = multiprocessing.Process(target=read_data)  # 创建子进程, copy一份主进程中的资源
+                                                    # 对自己进程中的资源进行操作
+
+    p1.start()
+    p2.start()
+
+    # 设置守护进程
+    # p1.daemon = True    # 设置为守护进程, 主进程结束, 子进程也结束
+    # p2.daemon = True    # 设置守护进程
+
+    # 在主进程结束前, 强制销毁所有子进程
+    #p1.terminate()
+    #p2.terminate()
+
+    # 等待子进程终止
+    p1.join()
+    p2.join()
+
+    print("主进程结束")
+
+if __name__ == '__main__':
+    main()
diff --git a/AI Learn/Stage 2 Python Advanced/Chapter 1 Python Advanced Programing/2.1-2 装饰器.ipynb b/AI Learn/Stage 2 Python Advanced/Chapter 1 Python Advanced Programing/2.1-2 装饰器.ipynb
@@ -389,13 +389,35 @@
    ],
    "execution_count": 8
   },
+  {
+   "metadata": {
+    "ExecuteTime": {
+     "end_time": "2024-12-14T10:52:38.184335Z",
+     "start_time": "2024-12-14T10:52:38.149720Z"
+    }
+   },
+   "cell_type": "code",
+   "source": "",
+   "id": "6e9c5cf78dd6ff2c",
+   "outputs": [
+    {
+     "name": "stdout",
+     "output_type": "stream",
+     "text": [
+      "executing the program\n",
+      "2\n"
+     ]
+    }
+   ],
+   "execution_count": 1
+  },
   {
    "metadata": {},
    "cell_type": "code",
    "outputs": [],
    "execution_count": null,
    "source": "",
-   "id": "6e9c5cf78dd6ff2c"
+   "id": "d4a3bf0e985209af"
   }
  ],
  "metadata": {
