日韩av黄I国产麻豆传媒I国产91av视频在线观看I日韩一区二区三区在线看I美女国产在线I麻豆视频国产在线观看I成人黄色短片

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 >

python守护多线程_Python守护进程(多线程开发)入门实例

發布時間:2024/9/19 42 豆豆
生活随笔 收集整理的這篇文章主要介紹了 python守护多线程_Python守护进程(多线程开发)入门实例 小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

這篇文章主要為大家詳細介紹了Python守護進程(多線程開發)入門實例,具有一定的參考價值,可以用來參考一下。

對python這個高級語言感興趣的小伙伴,下面一起跟隨512筆記的小編兩巴掌來看看吧!

# @param Python守護進程(多線程開發)

# @author 512筆記|512pic.com

#!/usr/bin/python

import sys,time,json,logging

import Queue, threading, datetime

from lib.base.daemon import Daemon

from lib.queue.httpsqs.HttpsqsClient import HttpsqsClient

from lib.db.DbMongodb import DbMongodb

logging.basicConfig(level=logging.DEBUG,

format='%(asctime)s %(filename)s[line:%(lineno)d] %(levelname)s %(message)s',

datefmt='%a, %d %b %Y %H:%M:%S',

filename='myapp.log',

filemode='w')

queue = Queue.Queue()

httpsqs = HttpsqsClient('192.168.0.218','1218','httpsqs.com')

db = DbMongodb('192.168.0.119','testdb')

class ThreadGetHttpSqs(threading.Thread):

def __init__(self):

threading.Thread.__init__(self)

self.httpsqs = httpsqs

self.queue = queue

def run(self):

while True:

data = self.httpsqs.get('logtest')

if data is not None:

self.queue.put(data)

logging.info('get:id %s , tablename %s' % (self.getName(),data))

else:

time.sleep(3)

class ThreadInsertDB(threading.Thread):

def __init__(self):

threading.Thread.__init__(self)

self.queue = queue

self.db = db

def run(self):

while True:

chunk = self.queue.get()

s = json.loads(chunk)

tablename = s['table']

data = s['data']

self.db.save(tablename,data)

logging.info('insert:id %s , tablename %s' % (self.getName(),tablename))

self.queue.task_done()

class MyDaemon(Daemon):

def _run(self):

while True:

for i in range(2):

t = ThreadGetHttpSqs()

#t.setDaemon(True)

t.start()

for i in range(2):

b = ThreadInsertDB()

#t.setDaemon(True)

b.start()

#線程已經為永真循環,進程不能再循環

time.wait()

if __name__ == "__main__":

daemon = MyDaemon('/tmp/daemon-example.pid')

if len(sys.argv) == 2:

if 'start' == sys.argv[1]:

daemon.start()

elif 'stop' == sys.argv[1]:

daemon.stop()

elif 'restart' == sys.argv[1]:

daemon.restart()

else:

print "Unknown command"

sys.exit(2)

sys.exit(0)

else:

print "usage: %s start|stop|restart" % sys.argv[0]

sys.exit(2)

# End www_512pic_com

注:關于Python守護進程(多線程開發)入門實例的內容就先介紹到這里,更多相關文章的可以留意512筆記的其他信息。

關鍵詞:守護進程

總結

以上是生活随笔為你收集整理的python守护多线程_Python守护进程(多线程开发)入门实例的全部內容,希望文章能夠幫你解決所遇到的問題。

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