在給定的利率執行特定的語句在Python

Question

我希望編寫執行每秒鐘指定語句數目的代碼， 你們中許多人可能是熟悉並且對長期利率

在這裏，我想速率爲每秒30

說，我想執行一個功能每秒30次60秒 意味着率= 30 /秒，持續時間= 60秒

任何一個可以告訴我是他們的任何API提供蟒蛇做一樣嗎？

Answer 1

一段時間的支出後，我發現瞭如何把它做好，我用多處理在Python實現它 這裏是我的解決方案

#!/usr/bin/env python 
from multiprocessing import Process 
import os 
import time 
import datetime 
def sleeper(name, seconds): 
    time.sleep(seconds) 
    print "PNAME:- %s"%name 


if __name__ == '__main__': 
    pros={} 
    processes=[] 
    i=0 
    time2=0 
    time1=datetime.datetime.now() 
    for sec in range(5): 
     flag=0 
     while flag!=1: 
       time2=datetime.datetime.now() 
       if (time2-time1).seconds==1: 
         time1=time2 
         flag=1 
         print "Executing Per second" 
         for no in range(5): 
           i+=1 
           pros[i] = Process(target=sleeper, args=("Thread-%d"%i, 1)) 
         j=i-5 
         for no in range(5): 
           j+=1 
           pros[j].start() 
         j=i-5 
         for no in range(5): 
           j+=1 
           processes.append(pros[j]) 
    for p in processes: 
     p.join() 

Answer 2

嘗試使用threading.Timer：

def hello(): 
    print "hello, world" 

t = Timer(30.0, hello) 
t.start() # after 30 seconds, "hello, world" will be printed 

Answer 3

您可以使用time.time()做你想要什麼：

import time 

def your_function(): 
    # do something... 

while True: 
    start = time.time() # gives current time in seconds since Jan 1, 1970 (in Unix) 
    your_function() 
    while True: 
     current_time = time.time() 
     if current_time - start >= 1.0/30.0: 
      break 

這將確保的your_function通話之間的延遲非常接近1/30一秒鐘，即使your_function需要一些時間才能運行。

還有一種方法：使用Pythons內置的調度模塊sched。我從來沒有用過它，所以我不能幫助你，但看看它。

Answer 4

的sched模塊是爲正是這一點：

from __future__ import division 
import sched 
import time 

scheduler = sched.scheduler(time.time, time.sleep) 

def schedule_it(frequency, duration, callable, *args): 
    no_of_events = int(duration/frequency) 
    priority = 1 # not used, lets you assign execution order to events scheduled for the same time 
    for i in xrange(no_of_events): 
     delay = i * frequency 
     scheduler.enter(delay, priority, callable, args) 

def printer(x): 
    print x 

# execute printer 30 times a second for 60 seconds 
schedule_it(1/30, 60, printer, 'hello') 
scheduler.run() 

對於線程環境，使用sched.scheduler可以替換爲threading.Timer：

from __future__ import division 
import time 
import threading 

def schedule_it(frequency, duration, callable, *args, **kwargs): 
    no_of_events = int(duration/frequency) 
    for i in xrange(no_of_events): 
     delay = i * frequency 
     threading.Timer(delay, callable, args=args, kwargs=kwargs).start() 

def printer(x): 
    print x 

schedule_it(5, 10, printer, 'hello')