Come faccio a gestire le librerie Lua che non fanno coroutine.yield()?

Question

Voglio scaricare un file di grandi dimensioni e gestire contemporaneamente altre cose.

Tuttavia, luasocket.http non chiama mai coroutine.yield(). Tutto il resto si blocca mentre il file viene scaricato.

Ecco un esempio illustrativo, in cui cerco di scaricare contemporaneamente un file e stampare alcuni numeri:

local http = require'socket.http' 

local downloadRoutine = coroutine.create(function() 
    print 'Downloading large file' 
    -- Download an example file 
    local url = 'http://ipv4.download.thinkbroadband.com/5MB.zip' 
    local result, status = http.request(url) 
    print('FINISHED download ('..status..', '..#result..'bytes)') 
end) 

local printRoutine = coroutine.create(function() 
    -- Print some numbers 
    for i=1,10 do 
     print(i) 
     coroutine.yield() 
    end 
    print 'FINISHED printing numbers' 
end) 

repeat 
    local printActive = coroutine.resume(printRoutine) 
    local downloadActive = coroutine.resume(downloadRoutine) 
until not downloadActive and not printActive 
print 'Both done!' 

esecuzione produce questo:

1 
Downloading large file 
FINISHED download (200, 5242880bytes) 
2 
3 
4 
5 
6 
7 
8 
9 
10 
FINISHED printing numbers 
Both done! 

Come si può vedere, printRoutine è resume d prima. Stampa il numero 1 e yield s. Il downloadRoutine è quindi resume d, che scarica l'intero file, senza produrre. Solo allora vengono stampati i restanti numeri.

Non voglio scrivere la mia libreria di socket! Cosa posso fare?

Modifica (più tardi lo stesso giorno): Alcuni utenti MUSH have also noticed. Forniscono idee utili.

Answer 1

Non vedo perché non è possibile utilizzare PiL advice o copas library (questa è quasi la stessa risposta di here).

Copas avvolge l'interfaccia socket (non socket.http), ma è possibile utilizzare l'interfaccia a basso livello per ottenere quello che ti serve con qualcosa di simile (non testato):

require("socket") 
local conn = socket.tcp() 
conn:connect("ipv4.download.thinkbroadband.com", 80) 
conn:send("GET /5MB.zip HTTP/1.1\n\n") 
local file, err = conn:receive() 
print(err or file) 
conn:close() 

È quindi possibile utilizzare addthread da copas a Dare un socket non bloccante e utilizzare le funzioni step/loop per fare receive mentre c'è qualcosa da ricevere.

L'uso di copas è meno efficace, mentre l'utilizzo di settimeout(0) offre un maggiore controllo.

Answer 2

Le coroutine non sono fili; sono cooperativi, non simultanei. Quando una coroutine cede a/da un altro, viene bloccata. Non puoi avere due puntatori di esecuzione simultanei in vanilla Lua.

Tuttavia, è possibile utilizzare librerie esterne per questo effetto. Uno dei più popolari è Lua Lanes.