Python 2 - threadin käynnistäminen + callback parametrina

Minun pitäisi tehdä Pythonilla softa, joka käynnistää erillisessä threadissa UDP listenerin (eri nuuskitaan tietystä IP-osoitteesta ja portista tulevaa UDP-liikennettä. Säikeelle pitäisi pystyä myös välittämään callback-funktio, koska listenerin pitäisi pystyä tarpeen mukaan lähettämään tietoa kutsujalle. Olen kokeillut määritellä python-luokan, jossa on yhtenä osana thread-funktio muodossa

def listener(self, callback=None):
...

Ja käynnistysfunktiossa joko muodossa

lt = Threading.thread(target=listener, args=(callback));

tai

lt = Threading.thread(target=listener, args=[callback]);

callback annetaan parametrina kutsuvalle funktiolle, jota kutsutaan tyyliin

startlistener(data_handler)

ja itse käsittelyfunktio on määritelty

def data_handler(data):
...

Ensimmäinen tapaus antaa virheen, jonka mukaan parametrin pitäisi olla iterable, toinen tapaus valittaa, että bind tarvitsee vain yhden parametrin, mutta oli annettu 2. Python ei ole vahvuuksiani, mutta sattuneesta syystä homma käytännössä täytyy tehdä sillä (ja nimen omaan kakkosversiolla).
4239
Äänestä

Muut lukivat myös

Vastaukset 4

Vanhimmat

Ensimmäisessä tapauksessa python ei todennäköisesti ymmärrä argumenttiasi tuple-tyyppisenä, jos se kerran valittaa ettei se ole iteroituva.

Toisessa tapauksessa olet todennäköisesti mokannut "self" -määreen kanssa, mikä on aika tyypillinen moka python-tyylisessä olio-ohjelmoinnissa. Luokan sisällä olevien funktioiden ensimmäinen argumentti on aina "self', joka viittaa isäntäolioon.

Äänestä

Tarkistin kyseisen luokkamäärittelyn. Luokassa kaikissa funktioissa on alussa self, kuten pitääkin. Kokeilin myös muuttaa listenerin alustuksessa parametrimäärittelyn muodosta "args=(callback)" muotoon "args=(callback,)" kuten olen nähnyt esimerkkikoodeissa, jolloin tuli taas tuo bind-virhe.

Mistä tuli mieleen. Koodissa bind-funktiota käytetään tuon soketin bindaukseen (kirjoitin sen esimerkkikoodien mukaisesti). Nykyisellään soketin luonti ja bindaus tehdään seuraavasti:

listen_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
listen_socket.bind(self.ip_address, self.port)

tuossa siis jäsenet ip_address ja port on asetettu etukäteen. Voisiko olla, että katsomani esimerkki viittasi Python 3:een, jossa on eri muotoinen bindaus ja tuo kakkosen versio ei hyväksy portin numeroa parametrina vaan ottaa vastaan mistä tahansa portista tulevan datan ? Voidaanko portti siinä tapauksessa määritellä jotenkin muuten vai pitääkö portti tarkistaa kullekin vastaanotetulle paketille erikseen ? Nykyisellään paketin vastaanottaminen tehdään seuraavasti:

data, addr = listen_socket.recvfrom(2048)

(edelleen kopioitu esimerkeistä). Onko tuossa tapauksessa addr portin numero ?

Äänestä

vähän vanha ketju, mutta tuossa :
lt = Threading.thread(target=listener, args=(callback));
on virhe.
argumentit kuuluu antaa näin:
lt = Threading.thread(target=listener, args=(callback,));

eli toi pilkku on äärimmäisen oleellinen siinä ja se ei voi toimia ilman,

Äänestä

Kommentoi aloitusta


Anonyymi kirjoitti:

Minun pitäisi tehdä Pythonilla softa, joka käynnistää erillisessä threadissa UDP listenerin (eri nuuskitaan tietystä IP-osoitteesta ja portista tulevaa UDP-liikennettä. Säikeelle pitäisi pystyä myös välittämään callback-funktio, koska listenerin pitäisi pystyä tarpeen mukaan lähettämään tietoa kutsujalle. Olen kokeillut määritellä python-luokan, jossa on yhtenä osana thread-funktio muodossa

def listener(self, callback=None):
...

Ja käynnistysfunktiossa joko muodossa

lt = Threading.thread(target=listener, args=(callback));

tai

lt = Threading.thread(target=listener, args=[callback]);

callback annetaan parametrina kutsuvalle funktiolle, jota kutsutaan tyyliin

startlistener(data_handler)

ja itse käsittelyfunktio on määritelty

def data_handler(data):
...

Ensimmäinen tapaus antaa virheen, jonka mukaan parametrin pitäisi olla iterable, toinen tapaus valittaa, että bind tarvitsee vain yhden parametrin, mutta oli annettu 2. Python ei ole vahvuuksiani, mutta sattuneesta syystä homma käytännössä täytyy tehdä sillä (ja nimen omaan kakkosversiolla).

Anonyymi
5000

Ilmoita asiaton sisältö

  • Sisältää materiaalia, joka on loukkaavaa, herjaavaa, rasistista, uhkailevaa tai ahdistelevaa.

  • Materiaali sisältää nimiä, yhteystietoja tai muita henkilökohtaisia tietoja. Julkisuuden henkilöistä, julkisissa viroissa toimivista ihmisistä sekä yritysten vastuuhenkilöistä saa keskustella työhön liittyen. Myös yksityiselämään liittyvistä asioista voi keskustella siltä osin, kuin niistä on julkisesti kerrottu.

  • Sisältää lapsille haitallista tai heiltä kiellettyä materiaalia. Seksuaalinen sisältö on sallittua aiheeseen tarkoitetuilla palstoilla, joiden ikäraja on 18 vuotta.

  • Lainvastaista sisältöä voi olla mm. yksityiselämää loukkaavan tiedon levitys, kiihottaminen kansanryhmää vastaan, laiton uhkaaminen, alaikäisiin liittyvä seksuaalinen sisältö/grooming, petokset, identiteettivarkaudet, kunnianloukkaukset ja tekijänoikeusrikkomukset.

  • Sisältö ei liity palstan tai keskusteluketjun aiheeseen.

  • Viesti ei ole suomea tai ruotsia (pl. International Forums), se sisältää mainontaa, se sisältää tekijänoikeuksin suojattua materiaalia, se on massapostitus tai jokin muu syy.

Jaa keskustelu