Wie gehe ich mit Lua-Bibliotheken um, die nicht coroutine.yield() enthalten?

Question

Ich möchte eine große Datei herunterladen und gleichzeitig andere Dinge behandeln.

Jedoch ruft luasocket.http nie coroutine.yield(). Alles andere friert beim Herunterladen der Datei ein.

Hier ist ein anschauliches Beispiel, in dem ich versuche, gleichzeitig eine Datei herunterzuladen und einige Zahlen drucken:

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!' 

Laufen sie dies erzeugt:

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

Wie Sie sehen können, printRoutine ist resume d zuerst. Es druckt die Nummer 1 und yield s. Die downloadRoutine ist dann resume d, die die gesamte Datei herunterlädt, ohne zu ergeben. Nur dann werden die restlichen Zahlen gedruckt.

Ich möchte nicht meine eigene Socket-Bibliothek schreiben! Was kann ich tun?

Bearbeiten (später am selben Tag): Einige MUSH-Benutzer have also noticed. Sie bieten hilfreiche Ideen.

Answer 1

Ich sehe nicht, warum Sie PiL advice oder copas library nicht verwenden können (das ist fast die gleiche Antwort wie here gegeben).

Copas wickelt die Socket-Schnittstelle (nicht socket.http), aber Sie können niedrige Level-Schnittstelle verwenden zu bekommen, was man mit so etwas wie dieses benötigen (nicht getestet):

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() 

Sie dann addthread von copas verwenden können, um Geben Sie einen nicht blockierenden Socket und verwenden Sie step/loop Funktionen, receive zu tun, während es etwas zu empfangen gibt.

Mit Copas ist weniger Arbeit, während die Verwendung settimeout(0) direkt gibt Ihnen mehr Kontrolle.

Answer 2

Coroutines sind keine Threads; sie sind kooperativ, nicht gleichzeitig. Wenn eine Coroutine zu einer anderen kommt, wird sie blockiert. Sie können in Vanilla Lua nicht zwei Ausführungszeiger gleichzeitig ausführen.

Sie können jedoch externe Bibliotheken zu diesem Zweck verwenden. Einer der beliebtesten ist Lua Lanes.