| Flutter Linux Embedder |

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

176 {
177 g_autoptr(GMutexLocker) locker = g_mutex_locker_new(&self->mutex);
178 (void)locker; // unused variable
179
180 g_return_if_fail(self->blocking_main_thread == FALSE);
181
182 g_object_ref(self);
183
184 self->blocking_main_thread = true;
185 while (self->blocking_main_thread) {
186 g_cond_wait_until(&self->cond, &self->mutex,
187 fl_task_runner_next_task_expiration_time_locked(self));
188 fl_task_runner_process_expired_tasks_locked(self);
189 }
190
191 // Tasks might have changed in the meanwhile, reschedule timeout
192 fl_task_runner_tasks_did_change_locked(self);
193
194 g_object_unref(self);
195 }

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

Referenced by fl_renderer_wait_for_frame().

## ◆ 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 154 of file fl_task_runner.cc.

154 {
155 FlTaskRunner* self =
156 FL_TASK_RUNNER(g_object_new(fl_task_runner_get_type(), nullptr));
157 g_weak_ref_init(&self->engine, G_OBJECT(engine));
158 return self;
159 }

Referenced by fl_engine_start().

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

163 {
164 g_autoptr(GMutexLocker) locker = g_mutex_locker_new(&self->mutex);
165 (void)locker; // unused variable
166
167 FlTaskRunnerTask* runner_task = g_new0(FlTaskRunnerTask, 1);
168 runner_task->task = task;
169 runner_task->task_time_micros =
170 target_time_nanos / kMicrosecondsPerNanosecond;
171
172 self->pending_tasks = g_list_append(self->pending_tasks, runner_task);
173 fl_task_runner_tasks_did_change_locked(self);
174 }

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

Referenced by fl_engine_post_task().

## ◆ 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 197 of file fl_task_runner.cc.

197 {
198 g_autoptr(GMutexLocker) locker = g_mutex_locker_new(&self->mutex);
199 (void)locker; // unused variable
200
201 g_return_if_fail(self->blocking_main_thread == TRUE);
202
203 self->blocking_main_thread = FALSE;
204 g_cond_signal(&self->cond);
205 }

References TRUE.

Referenced by fl_renderer_unblock_main_thread().

## ◆ G_DECLARE_FINAL_TYPE()

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

kMicrosecondsPerNanosecond
static constexpr int kMicrosecondsPerNanosecond
Definition: fl_task_runner.cc:8
_FlTaskRunnerTask::task_time_micros
gint64 task_time_micros
Definition: fl_task_runner.cc:26
fl_task_runner_process_expired_tasks_locked
static void fl_task_runner_process_expired_tasks_locked(FlTaskRunner *self)
Definition: fl_task_runner.cc:34
fl_task_runner_next_task_expiration_time_locked
static gint64 fl_task_runner_next_task_expiration_time_locked(FlTaskRunner *self)
Definition: fl_task_runner.cc:94
TRUE
return TRUE
Definition: fl_pixel_buffer_texture_test.cc:53
fl_task_runner_tasks_did_change_locked
static void fl_task_runner_tasks_did_change_locked(FlTaskRunner *self)
Definition: fl_task_runner.cc:106
_FlTaskRunnerTask::task
FlutterTask task
Definition: fl_task_runner.cc:27
_FlTaskRunnerTask
Definition: fl_task_runner.cc:24