#用類方法 服務端

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

轉載于:https://www.cnblogs.com/yanxiatingyu/p/9295187.html

總結

以上是生活随笔為你收集整理的python multiprocessing 和tcp的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。