#include <glib-object.h>
#include "flutter/shell/platform/embedder/embedder.h"
#include "flutter/shell/platform/linux/public/flutter_linux/fl_engine.h"

Functions
G_BEGIN_DECLS	G_DECLARE_FINAL_TYPE (FlTaskRunner, fl_task_runner, FL, TASK_RUNNER, GObject)

FlTaskRunner *	fl_task_runner_new (FlEngine *engine)

void	fl_task_runner_post_flutter_task (FlTaskRunner *task_runner, FlutterTask task, uint64_t target_time_nanos)

void	fl_task_runner_wait (FlTaskRunner *task_runner)

void	fl_task_runner_stop_wait (FlTaskRunner *self)

Function Documentation

◆ fl_task_runner_new()

FlTaskRunner * fl_task_runner_new ( FlEngine * engine )

fl_task_runner_new: @engine: the #FlEngine owning the task runner.

Creates new task runner instance.

Returns: an #FlTaskRunner.

Definition at line 147 of file fl_task_runner.cc.

                                                   {
  FlTaskRunner* self =
      FL_TASK_RUNNER(g_object_new(fl_task_runner_get_type(), nullptr));
  g_weak_ref_init(&self->engine, G_OBJECT(engine));
  return self;
}

References engine, and self.

Referenced by fl_engine_init(), TEST(), TEST(), TEST(), TEST(), TEST(), TEST(), TEST(), TEST(), and TEST().

◆ fl_task_runner_post_flutter_task()

void fl_task_runner_post_flutter_task	(	FlTaskRunner *	task_runner,
		FlutterTask	task,
		uint64_t	target_time_nanos
	)

fl_task_runner_post_flutter_task: @task_runner: an #FlTaskRunner. @task: Flutter task being scheduled @target_time_nanos: absolute time in nanoseconds

Posts a Flutter task to be executed on main thread. This function is thread safe and may be called from any thread.

Definition at line 154 of file fl_task_runner.cc.

                                                                  {
  g_autoptr(GMutexLocker) locker = g_mutex_locker_new(&self->mutex);
  (void)locker;  // unused variable
 
  FlTaskRunnerTask* runner_task = g_new0(FlTaskRunnerTask, 1);
  runner_task->task = task;
  runner_task->task_time_micros =
      target_time_nanos / kMicrosecondsPerNanosecond;
 
  self->pending_tasks = g_list_append(self->pending_tasks, runner_task);
  fl_task_runner_tasks_did_change_locked(self);
 
  // Tasks changed, so wake up anything blocking in fl_task_runner_wait.
  g_cond_signal(&self->cond);
}

References fl_task_runner_tasks_did_change_locked(), g_autoptr(), kMicrosecondsPerNanosecond, self, _FlTaskRunnerTask::task, and _FlTaskRunnerTask::task_time_micros.

Referenced by fl_engine_post_task().

◆ fl_task_runner_stop_wait()

void fl_task_runner_stop_wait ( FlTaskRunner * self )

fl_task_runner_stop_wait: @task_runner: an #FlTaskRunner.

Cause fl_task_runner_wait() to complete. May be called even if fl_task_runner_wait() is not being used.

May be called by any thread.

Definition at line 182 of file fl_task_runner.cc.

                                                  {
  g_cond_signal(&self->cond);
}

References self.

◆ fl_task_runner_wait()

void fl_task_runner_wait ( FlTaskRunner * task_runner )

fl_task_runner_wait: @task_runner: an #FlTaskRunner.

Block until the next task is ready and then perform it. May be interrupted by fl_task_runner_stop_wait(), in which case no task is run but execution will be returned to the caller.

Must be called only by the GTK thread.

Definition at line 172 of file fl_task_runner.cc.

                                             {
  g_autoptr(GMutexLocker) locker = g_mutex_locker_new(&self->mutex);
  (void)locker;  // unused variable
 
  g_cond_wait_until(&self->cond, &self->mutex,
                    fl_task_runner_next_task_expiration_time_locked(self));
  fl_task_runner_process_expired_tasks_locked(self);
  fl_task_runner_tasks_did_change_locked(self);
}

References fl_task_runner_next_task_expiration_time_locked(), fl_task_runner_process_expired_tasks_locked(), fl_task_runner_tasks_did_change_locked(), g_autoptr(), and self.

Referenced by fl_compositor_opengl_render(), and fl_compositor_software_render().

◆ G_DECLARE_FINAL_TYPE()