python - multiprocessing.Event.wait hangs when interrupted by a signal -

-

i use following code handle sigint event. code sets multiprocessing.event "wakeup" main thread waiting.

import multiprocessing import signal  class class1(object):     _stop_event = multiprocessing.event()      @staticmethod     def interrupt():         class1._stop_event.set()      def wait(self):         print("waiting _stop_event")         if class1._stop_event.wait(5):             print("_stop_event set.")         else:             print("timed out.")  def stop(signum, frame):     print("received sig")     class1.interrupt()  signal.signal(signal.sigint, stop)  c = class1() c.wait()

without signal, wait method times out after 10 seconds , process exits following output expected:

waiting _stop_event timed out.

when sending sigint signals, signal gets handled event.wait method not return, neither nor after timeout. process never exits. output is:

waiting _stop_event ^creceived sig

i can continue send sigints. process won't exit , output is:

waiting _stop_event ^creceived sig ^creceived sig ^creceived sig ^creceived sig ....

everything works expected if replace class1.wait method check event.is_set:

def wait(self):     print("waiting _stop_event")     while true:         if class1._stop_event.is_set():             print("_stop_event set.")             break

the process exits , output is:

waiting _stop_event ^creceived sig _stop_event set.

how make event.wait return once event set? reason wait method doesn't timeout anymore?

you guys going one. use threading.event, not multiprocessing.event. when press ^c signal handler called should!

source

import threading import signal  class class1(object):     _stop_event = threading.event()      @staticmethod     def interrupt():         class1._stop_event.set()      def wait(self):         print("waiting _stop_event")         if class1._stop_event.wait(5):             print("_stop_event set.")         else:             print("timed out.")  def stop(signum, frame):     print("received sig")     class1.interrupt()  signal.signal(signal.sigint, stop)  c = class1() c.wait()

output

waiting _stop_event ^creceived sig _stop_event set.

Comments

Post a Comment

Popular posts from this blog

sql server - MSSQL Text and Varchar(MAX) fields shown (MEMO) in DBGrid -

-
Image
i have encountered problem in mssql & delphi xe3. text , varchar(max) fields seemed (memo) or (widememo) in tdbgrid & tdbadvgrid (tms dbgrid). in first screenshot can see table fiels, in second screentshot can see sample data in database: in screenshot, see how in dbgrid or in query results. i figured out changing field type char , varchar not max solves issue don't know why having problem. can please let me know?
Read more

qml - Is it possible to implement SystemTrayIcon functionality in Qt Quick application -

-
i writing qtquick desktop application. use both c++ (for functionality) , qml (for ui) in it. use qquickview show interface written in qml. i want application reside in system tray when minimised. i mean functionality similar example. http://qt-project.org/doc/qt-4.8/desktop-systray.html . trying implement feature not find way in qt quick application. here main.cpp code: #include <qguiapplication> #include <qqmlengine> #include <qqmlcontext> #include <qqmlfileselector> #include <qquickview> #include "myapp.h" int main(int argc, char* argv[]) { qguiapplication app(argc,argv); app.setapplicationname(qfileinfo(app.applicationfilepath()).basename()); qdir::setcurrent(qapp->applicationdirpath()); myapp myappobject; qquickview view; view.connect(view.engine(), signal(quit()), &app, slot(quit())); view.rootcontext()->setcontextproperty("myappobject", &myappobject); new qqmlfilese...
Read more

mysql - Flyway migration, Unable to obtain Jdbc connection from DataSource -

-
i trying use flyway create , manage mysql database. here code have got far. flywaymigration.java : class applys migration public class flywaymigration { public flywaymigration(databaseconfiguration configuration, flyway flyway) { flyway.setdatasource(configuration.getdatasource()); flyway.migrate(); } public static void main(string[] args) { new flywaymigration(new databaseconfiguration("database.properties"), new flyway()); } } databaseconfiguration.java : configuration class, class configure datasource applyed flyway.setdatasource method public class databaseconfiguration { private final logger logger = loggerfactory.getlogger(this.getclass()); private propertiesutil prop = null; public databaseconfiguration(string file) { prop = new propertiesutil(file); } public string getdatasourceclass() { return prop.getproperty("mysql.data.source.class"); } pu...
Read more