#用類方法 服務端
from socket import *
from multiprocessing import Process
import os
class Myprocess(Process):
def __init__(self, conn):
self.conn = conn
super().__init__()
def run(self):
conn = self.conn
start = True
while start:
try:
print('啟動子線程:%s' % os.getpid(), end='')
data = conn.recv(1024)
conn.send(data)
print('線程編號:%s,data=%s' % (os.getpid(), data.decode('utf-8')))
except Exception as e:
conn.close()
start = False
print('關閉了')
conn.close()
if __name__ == '__main__':
# p=Myprocess('這是測試文件')
# p.start()
st = socket(AF_INET, SOCK_STREAM)
host = '127.0.0.1'
port = 8080
listen_number = 5
st.bind((host, port))
st.listen(listen_number)
transcript = None
while True:
print('等待連接')
conn, _ = st.accept()
if conn != transcript:
transcript = conn
p = Myprocess(conn)
p.start()
print('連接成功')
else:
print('不知道:%s' % conn)
st.close()
#用函數方法 服務端
from multiprocessing import Process
from socket import *
import json, struct
import os
def process_communication(conn):
while True:
try:
print('啟動子線程:%s' % os.getpid(), end='')
data = conn.recv(1024)
conn.send(data)
print('線程編號:%s,data=%s' % (os.getpid(), data.decode('utf-8')))
except Exception:
conn.close()
print('關閉了')
break
if __name__ == '__main__':
st = socket(AF_INET, SOCK_STREAM)
host = '127.0.0.1'
port = 8080
listen_number = 5
st.bind((host, port))
st.listen(listen_number)
transcript = None
while True:
print('等待連接')
conn, _ = st.accept()
if conn != transcript:
transcript = conn
p = Process(target=process_communication, args=(conn,))
p.start()
#p.join()
print('連接成功')
else:
print('不知道:%s' % conn)
st.close()
#客戶端
from socket import *
st = socket(AF_INET, SOCK_STREAM)
host = '127.0.0.1'
port = 8080
st.connect((host, port))
while True:
msg = input('請輸入:').strip()
if not len(msg):
continue
st.send(msg.encode(encoding = 'utf-8'))
data=st.recv(1024)
print(data.decode(encoding='utf-8'))
st.close()
(現代操作系統)書 egon老師推薦
開啟線程方式一：
import multiprocessing
from multiprocesssing import Process
def task(name):
print('%s is runings'%name)
time.sleep(3)
print('%s is done'%name)
group#保留參數 無用
target#任務名
#如果只有一個參數一定記住加 逗號(，)
#Process(target=task,kwargs={'name':'子進程'})
if __name__=='__main__':
p=Process(target=task,args=('子進程'，))
p.start()#windows系統倒模塊的方式，把父進程加載進去
#linux 其實不用放入main下面的，
#但是為了兼容liunx和windows系統 所以全部加吧
#可以自定義函數名
#主進程會等待子進程結束后才會結束
p.start()#只是在操作系統發送一個開啟子進程的信號
#p.start只是發送信號(這步速度非常快)
#申請內存空間，開辟個名稱空間，在將父進程的數據復制一份到這個內存空間中
#至于開啟的時間，開啟的方式都是操作系統說的算
class Myprocess(Process):
def __init__(self,x):
super().__init__()
self.name=x
def run(self):
self.name#進程名稱
if __name__=='__main__':
p=Myprocess('測試')
p.start()#等同于p.run()#自定義類必須實現run()方法
import time
x='tiankong'
def task():
global x
x=0
print('done')
print(x)
if __name__ == '__main__':
p=Process(target=task)
p.start()
time.sleep(5)#讓父進程等待5秒，讓子進程運行完閉后，才執行下一行代碼
print(x) #但是子進程不一定5秒就能運行完。、
#進程間內存隔離
from multiprocessing import Process
import time,os
def task(name,n):
print('name is :%s'%name)
time.sleep(3)
print('子進程pid%s'%os.getpid())
print(n)
print('end')
if __name__ == '__main__':
p=Process(target=task,args=('子進程',('這里可以給子進程傳參')))
p.start()
p.pid#父進程查看 子進程的pid方式
p.join()#讓父進程在原地等待，等到子進程運行完畢后，才執行下一行代碼
#本質和time.sleep()一樣但是等待時間不用手動輸入了
print('主進程')
def walk():
print('walk:%s'%os.getpid())
time.sleep(12)
if __name__ == '__main__':
p=Process(target=walk)
p.start()
p.is_alive()#只要信號發出，就認為這個子線程是活著
print('父進程:%s'%os.getpid())
p.join()#自動回收僵尸進程
#讓父進程進入等待狀態
p.terminate()#給操作系統發送信號，殺死這個子進程
#殺死進程taskkill /F /PID 進程號
#liunx 中孤兒進程 父進程會變成 init
