#进程池创建进程
#进程池是用来创建成百上千的多个进程

from multiprocessing import Pool
import random,time

def work(num):
    print(random.random()*num)
    time.sleep(3)

if __name__ == "__main__":
    po = Pool(3)    #定义一个进程池，最大进程数为3，默认大小为CPU核数
    for i in range(10):
        po.apply_async(work,(i,))   #apply_async选择要调用，每次循环会用空出来的子进程去调用目标
    po.close()    #进程池关闭之后不再接收新的请求，但是之前已经接收的请求会执行完
    po.join()     #等待po中所有子进程结束，必须放在close后面

#在多进程中：主进程一般用来等待，真正的任务都在子进程中执行

为什么按着代码敲完，运行的时候没有结果，程序也一直在运行中

#进程间通信---Queue
#通过Queue（队列Q）可以实现进程间的数据传递
#Q本身是一个消息队列

from multiprocessing import Process
from multiprocessing import Pool
from multiprocessing import Queue

def run1(q):
    q.put("消息")
    q.put("消息")

def run2(q):
    print(q.qsize())
    print(q.get())
    print(q.qsize())

if __name__ == "__main__":
    q = Queue(3)
    p1 = Process(target=run1,args=(q,))
    p2 = Process(target=run2,args=(q,))
    p1.start()
    p2.start()
    p1.join()
    p2.join()

multiprocessing
time

write(q):
    i :
        (,i)
        q.put(i)
read(q):
    time.sleep()
    i (q.qsize()):
        (,q.get())
__name__ == :
    q = multiprocessing.Manager().Queue()
    po = multiprocessing.Pool()
    po.apply_async(write,(q,))
    po.apply_async(read,(q,))
    po.close()
    po.join()

老师这个运行不出结果

multiprocessing
time

write(q):
    value [,,]:
        (,value)
        q.put(value)
        time.sleep()

read(q):
    :
        q.empty():
            (,q.get())
            time.sleep()
        :
            __name__ == :
    q = multiprocessing.Queue()
    pw = multiprocessing.Process(= write,=(q,))
    pr = multiprocessing.Process(= read,=(q,))
    pw.start()
    pw.join()

    pr.start()
    pr.join()
    ()

复制的程序 执行结果不对

进程，线程的调用对象不是太明白

他们的调用对象只能是函数，类吗？可以是模块，项目吗？

a，b两个进程同时运行，如何实现a进程停止时，不管b进程运行不运行，实现b进程的停止运行。   

主进程创建子进程，那子进程可以创建子进程吗，还是子进程下吗没有了，就只有多个线程了呢？

老师您好

如下图所示，为什么报错threading中没有Thread这个属性呢

from socket import *
import time

host = 'localhost'
port = 8080
addr =(host,port)
bufferSize = 10
fullData = b''
tcpServerSocket = socket(AF_INET,SOCK_STREAM)
tcpServerSocket.bind(addr)
print('********服务器正在监听********')
tcpServerSocket.listen(5)
tcpClientSocket,addr = tcpServerSocket.accept()
while True:
    data = tcpClientSocket.recv(bufferSize)
    fullData += data
    if len(data) < bufferSize :
        break
print(time.ctime()+'\n'+fullData.decode(encoding='utf-8'))
print('********给客户端发送确认消息********')
tcpClientSocket.send(time.ctime().encode(encoding='utf-8')+b'\n'+'已收到客户端请求'.encode('utf-8'))
tcpClientSocket.close()
tcpServerSocket.close()

老师好！ 我设置的bufferSize =10     我从客户端输入10个字节的字符 比如helloworld 服务器端都不会有响应，其他情况都可以。我知道是因为data长度为10的时候，进程正好读完，进程并没有读下一次使break执行，但是改怎么改呢？请老师指教

from socket import *
import time

host = 'localhost'
port = 8080
addr =(host,port)
bufferSize = 10
fullData = b''
tcpServerSocket = socket(AF_INET,SOCK_STREAM)
tcpServerSocket.bind(addr)
print('********服务器正在监听********')
tcpServerSocket.listen(5)
tcpClientSocket,addr = tcpServerSocket.accept()
while True:
    data = tcpClientSocket.recv(bufferSize)
    fullData += data
    if len(data) < bufferSize :
        break
print(time.ctime()+'\n'+fullData.decode(encoding='utf-8'))
print('********给客户端发送确认消息********')
tcpClientSocket.send(time.ctime().encode(encoding='utf-8')+b'\n'+'已收到客户端请求'.encode('utf-8'))
tcpClientSocket.close()
tcpServerSocket.close()

老师好！ 我设置的bufferSize =10     我从客户端输入10个字节的字符 比如helloworld 服务器端都不会有响应，其他情况都可以。我知道是因为data长度为10的时候，进程正好读完，进程并没有读下一次使break执行，但是改怎么改呢？请老师指教

'''
建立一次通讯
'''
from socket import *

tcpServerSocket = socket(AF_INET,SOCK_STREAM)
host = ''
post = 8080
addr = (host,post)
tcpServerSocket.bind(addr)
print('----------等待会话开始------------')
while True:
    tcpServerSocket.listen()
    tcpClientSocket,addr = tcpServerSocket.accept()
    data = tcpClientSocket.recv(1024)
    print('对方发给你的话：',end=' ')
    print(data.decode(encoding='gb2312'))
    sendData = input('请输入发给对方的话：')
    tcpClientSocket.send(sendData.encode(encoding='gb2312'))

老师 我利用网络助手反复测试了这个代码，出现了一下问题：

        我能接受到网络助手发送的信息，而且我能给网络助手发信息。但是只能接受一次，再次发送就收不到了，为什么呢？？

'''
测试多进程的数据交换
从write()中写入数据，从read()中读取数据并打印
'''
import multiprocessing
import time
q = multiprocessing.Queue()
def write():
    for value in ['a','b','c']:
        print("已经输入:",value)
        q.put(value)
        time.sleep(1)

def read():
    while True:
        if q.empty() != False:
            print('获取的数据是：',q.get())
            time.sleep(1)
        else:
            break


if __name__ == '__main__':
    pw = multiprocessing.Process(target = write )
    pr = multiprocessing.Process(target = read )
    pw.start()
    pw.join()
    pr.start()
    pr.join()
    print('接收完毕')

运行结果：

已经输入: a
已经输入: b
已经输入: c

没有显示接受 老师这个是为什么呀

from multiprocessing import Process

def loop(n):
    for i in range(n):
        print("子进程开始，第{0}次".format(i))

if __name__ == '__main__':
    p = Process( target = loop , args = (5,),name = '进程-1')
    for i in range(5):
        print('父进程开始')
        p.start()
    p.join()

运行结果显示：报错：不能调用一个进程两次

def loop(n):
    for i in range(n):
        print("子进程开始，第{0}次".format(i))
if __name__ == '__main__':
    for i in range(5):
        print('父进程开始')
        loop(5)
        
打印的结果正常

老师可否解释下第一段代码报错的原因

import threading
import time
from queue import Queue
class Pro(threading.Thread):
    def run(self):
        global qu
        count=0
        while True:
            if qu.qsize()<1000:
                for i in range(100):
                    count+=1
                    msg="生成产品"+str(count)
                    qu.put(msg)
                    print(msg)
            time.sleep(1)
class Con(threading.Thread):
    def run(self):
        global qu
        while True:
            if qu.qsize()>100:
                for i in range(3):
                    msg=self.name+"消费了"+qu.get()
                    print(msg)
            time.sleep(1)
if __name__=="__main__":
    qu=Queue
    for i in range(500):
        qu.put("初始产品"+str(i),)
    for i in range(2):
        p=Pro()
        p.start()
    for i in range(5):
        c=Con()
        c.start()

代码跟老师的一样，为什么会报这样的错？？？？？？？？？？

Traceback (most recent call last):

  File "C:/Users/齐泉/PycharmProjects/1/test2.py", line 28, in <module>

    qu.put("初始产品"+str(i))

TypeError: put() missing 1 required positional argument: 'item'

Process finished with exit code 1