Funzione di spegnimento senza attendere risposta (Python)

Question

Ho un flusso di link in arrivo, e voglio controllarli per rss di tanto in tanto. Ma quando sparo la mia funzione get_rss(), blocca e il flusso si arresta. Questo è inutile, e mi piacerebbe solo fire-and-forget sulla funzione get_rss() (memorizza i propri risultati altrove.)

Il mio codice è come così:

self.ff.get_rss(url) # not async 
print 'im back!' 

(...) 

def get_rss(url): 
    page = urllib2.urlopen(url)  # not async 
    soup = BeautifulSoup(page) 

sto pensando che se posso licenziare e dimenticare la prima chiamata, allora posso anche usare urllib2 senza preoccuparmi che non sia asincrona. Ogni aiuto è molto apprezzato!

Edit: Provare gevent, ma come questo non succede nulla:

print 'go' 
g = Greenlet.spawn(self.ff.do_url, url) 
print g 
print 'back' 

# output: 
go 
<Greenlet at 0x7f760c0750f0: <bound method FeedFinder.do_url of <rss.FeedFinder object at 0x2415450>>(u'http://nyti.ms/SuVBCl')> 
back 

La Greenlet sembrano essere registrata, ma la funzione self.ff.do_url(url) non sembra essere funzionare affatto. Che cosa sto facendo di sbagliato?

Answer 1

si desidera utilizzare il modulo o il modulo threadingmultiprocessing e salvare il risultato sia in database, un file o un queue.

È inoltre possibile utilizzare gevent.

Answer 2

Fuoco e dimenticare utilizzando il modulo multiprocessing:

def fire_and_forget(arg_one): 
    # do stuff 
    ... 

def main_function(): 
    p = Process(target=fire_and_forget, args=(arg_one,)) 
    # you have to set daemon true to not have to wait for the process to join 
    p.daemon = True 
    p.start() 
    return "doing stuff in the background"