fl_task_runner.h File Reference

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

Go to the source code of this file.

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_task (FlTaskRunner *task_runner, FlutterTask task, uint64_t target_time_nanos)
void	fl_task_runner_block_main_thread (FlTaskRunner *task_runner)
void	fl_task_runner_release_main_thread (FlTaskRunner *self)

Function Documentation

fl_task_runner_block_main_thread()

void fl_task_runner_block_main_thread

(

FlTaskRunner *

task_runner

)

fl_task_runner_block_main_thread: @task_runner: an #FlTaskRunner.

Blocks main thread until fl_task_runner_release_main_thread is called. While main thread is blocked tasks posted to #FlTaskRunner are executed as usual. Must be invoked on main thread.

Definition at line 184 of file fl_task_runner.cc.

                                                          {
  g_autoptr(GMutexLocker) locker = g_mutex_locker_new(&self->mutex);
  (void)locker;  // unused variable
 
  g_return_if_fail(self->blocking_main_thread == FALSE);
 
  g_object_ref(self);
 
  self->blocking_main_thread = true;
  while (self->blocking_main_thread) {
    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);
  }
 
  // Tasks might have changed in the meanwhile, reschedule timeout
  fl_task_runner_tasks_did_change_locked(self);
 
  g_object_unref(self);
}

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 161 of file fl_task_runner.cc.

                                                   {
  FlTaskRunner* res =
      FL_TASK_RUNNER(g_object_new(fl_task_runner_get_type(), nullptr));
  res->engine = engine;
  g_object_weak_ref(G_OBJECT(engine), engine_weak_notify_cb, res);
  return res;
}

fl_task_runner_post_task()

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

fl_task_runner_post_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 169 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);
}

fl_task_runner_release_main_thread()

void fl_task_runner_release_main_thread

(

FlTaskRunner *

self

)

fl_task_runner_release_main_thread: @task_runner: an #FlTaskRunner.

Unblocks main thread. This will resume normal processing of main loop. Can be invoked from any thread.

Definition at line 205 of file fl_task_runner.cc.

                                                            {
  g_autoptr(GMutexLocker) locker = g_mutex_locker_new(&self->mutex);
  (void)locker;  // unused variable
 
  g_return_if_fail(self->blocking_main_thread == TRUE);
 
  self->blocking_main_thread = FALSE;
  g_cond_signal(&self->cond);
}

G_DECLARE_FINAL_TYPE()

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