#!/usr/bin/evn python

# -*- coding:utf-8 -*-

import threading

import Queue

import time

# 建立一個訊息佇列

message=Queue.Queue();

# 生產者的方法

def producer():

for i in range(0,10000):

# 把系統訊息壓到隊列當中去

message.put(item=str("simonQueue"+str(i)));

print("Push Message SuccessFully!!!!")

# 消費者的方法

def customClient():

for i in range(0,100):

# 把系統訊息從隊列當中取出

strs = message.get();

print("get Queue Message:" + strs)

for i in range(0,100):

time.sleep(1)

strs = message.get();

print("get Queue Message:" + strs)

produceth=threading.Thread(target=producer);

produceth.start();

customth=threading.Thread(target=customClient);

customth.start();