SocketServer and timers

[alf]

Hi,

I have one thread app using SocketServer and use server_forever() as a
main loop. All works fine, but now I need certain timer checking let's
say every 1 second something and stopping the main loop. So questions are:
-how to stop serve_forever
-how to implement timers

thx, alf

 

[bryanjugglercryptographer]

I have one thread app using SocketServer and use server_forever() as a
main loop. All works fine, but now I need certain timer checking let's
say every 1 second something and stopping the main loop. So questions are:
-how to stop serve_forever

Override serve_forever() and replace "while 1:" with something like
"while self.continue_flag:".

-how to implement timers

You could override get_request(), and use select.select() to wait for
either the socket to become readable (so the accept() won't block), or
a timeout to expire. If you are not already, use the threading or
forking
mixin so that the request handler won't stop everthing if it blocks.

 

[Simon Forman]

Hi,

I have one thread app using SocketServer and use server_forever() as a
main loop. All works fine, but now I need certain timer checking let's
say every 1 second something and stopping the main loop. So questions are:
-how to stop serve_forever
-how to implement timers

thx, alf

Do you really need a timer, or do you just want to check something
every second or so?

If the latter, then something like this would do it:

from time import time

INTERVAL = 1.0

RUN = True

while RUN:

# Get a time in the future.
T = time() + INTERVAL

# Serve requests until then.
while time() < T:
server.handle_request()

# Check whatever.
if check():
# Do something, for example, stop running.
RUN = False

HTH,
~Simon

 

[bryanjugglercryptographer]

Do you really need a timer, or do you just want to check something
every second or so?

If the latter, then something like this would do it:

from time import time

INTERVAL = 1.0

RUN = True

while RUN:

# Get a time in the future.
T = time() + INTERVAL

# Serve requests until then.
while time() < T:
server.handle_request()
# Check whatever.
if check():
# Do something, for example, stop running.
RUN = False

That alone does not work. If server.handle_request() blocks,
you don't get to the check(). You need some kind of timeout
in handle_request().

 

[Simon Forman]

That alone does not work. If server.handle_request() blocks,
you don't get to the check(). You need some kind of timeout
in handle_request().

Ach! You're right. I didn't consider that handle_request() might
block..

 

[alf]

Override serve_forever() and replace "while 1:" with something like
"while self.continue_flag:".




You could override get_request(), and use select.select() to wait for
either the socket to become readable (so the accept() won't block), or
a timeout to expire. If you are not already, use the threading or
forking
mixin so that the request handler won't stop everthing if it blocks.

thx for a suggestion, will try it out ...