FilesExpand file tree

 master

/

prodcons.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

48 lines (37 loc) · 1.12 KB

 master

/

prodcons.py

Copy path

Top

File metadata and controls

• Code
• Blame

48 lines (37 loc) · 1.12 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

from random import randrange

from time import sleep

from queue import Queue

from myThread3 import MyThread

# 实现一个生产者-消费者模式

# 生产者向队列中放入数据，而消费者取出数据使用

def writeQ(queue):

print('producing object for Q...', end='')

queue.put('xxx', True) # 将'xxx‘放入队列

print("size now", queue.qsize())

def readQ(queue):

val = queue.get(1) # 从队列中获取item

print('consumed object from Q... size now', queue.qsize())

def writer(queue, loops):

for i in range(loops):

writeQ(queue)

sleep(randrange(1, 4))

def reader(queue, loops):

for i in range(loops):

readQ(queue)

sleep(randrange(2, 6))

funcs = [writer, reader]

nfuncs = range(len(funcs))

def main():

nloops = randrange(2, 6)

q = Queue(32) # 初始化queue大小为32

threads = []

for i in nfuncs:

t = MyThread(funcs[i], (q, nloops), funcs[i].__name__)

threads.append(t)

for i in nfuncs:

threads[i].start()

for i in nfuncs:

threads[i].join()

print('all DONE')

if __name__ == '__main__':

main()