Running a task every few seconds

[ghnp5]

Hello,

I'm trying to have a task run every 5 seconds, to prevent the database connection from becoming stale.

$scheduler = new Scheduler();

$scheduler->add(function () : void {
	while (true) {
		try {
			write_log('Checking stale: '.(time() - Database::getLastAccessedTime()));
			if (time() - Database::getLastAccessedTime() > 60) {
				write_log('Reconnecting database...');
				Database::connect();
			}

			Coroutine::sleep(5);
		} catch (\Throwable $e) {
			write_log($e::class.': '.$e->getMessage());
		}
	}
});

$scheduler->start();

However, for some reason, this doesn't seem to run, or gets stuck, until I restart the docker container, where it appears to run and log at that point.

Is it because I'm running blocking operations here?

---

I also tried:

$timerId = Timer::tick(5000, function () : void {
	try {
		write_log('Checking stale: '.(time() - Database::getLastAccessedTime()));
		if (time() - Database::getLastAccessedTime() > 60) {
			write_log('Reconnecting database...');
			Database::connect();
		}
	} catch (\Throwable $e) {
		write_log($e::class.': '.$e->getMessage());
	}
});

but this doesn't seem to run at all.

---

I'm also confused how to run Coroutine, with create, run and resume.. :)

---

Can I run blocking operations in Scheduler and/or Coroutine ?

What's the best way to run a simple task every 5 seconds (or every minute), that accepts blocking operations, and has access to the variables in the global scope, such as the global database connection?

Thank you very much!

[NathanFreeman]

Swoole\Runtime::enableCoroutine($flags = SWOOLE_HOOK_ALL);

$connection = null;
$timerId = Timer::tick(5000, function () : void {
	try {
		write_log('Checking stale: '.(time() - Database::getLastAccessedTime()));
		if (time() - Database::getLastAccessedTime() > 60) {
		      global $connection;
                      write_log('Reconnecting database...');
		      $connection = Database::connect();
		}
	} catch (\Throwable $e) {
		write_log($e::class.': '.$e->getMessage());
	}
});
Swoole\Event::wait();

[NathanFreeman]

You can not run blocking operations in the timer otherwise it will affect the next task execution if you have not enabled coroutine hook.

[ghnp5]

Thank you very much.

What you are saying is that if I put Swoole\Runtime::enableCoroutine($flags = SWOOLE_HOOK_ALL);, then I can run blocking operations, is that correct?

I made the changes as suggested, but it is still not triggering, for some reason :(
(at least the log isn't writing)

[NathanFreeman]

The PHP blocking functions will turn to non-blocking function if you put Swoole\Runtime::enableCoroutine($flags = SWOOLE_HOOK_ALL);

You can execute your code in a non docker environment to find where the problem is.