1b646804ea
... which runs a user-provided function asynchronously, returning a corresponding GimpAsync object. This can be used to execute code off the main thread, using the GimpAsync object to synchronize as necessary. Note that while the code allows for running multiple asynchronous functions in parallel in a thread pool, we currently limit the pool to a single thread, queueing overlapping async function, since we have no use for parallel asynchronous functions at the moment.
141 lines
5.8 KiB
C++
141 lines
5.8 KiB
C++
/* GIMP - The GNU Image Manipulation Program
|
|
* Copyright (C) 1995 Spencer Kimball and Peter Mattis
|
|
*
|
|
* gimp-parallel.h
|
|
* Copyright (C) 2018 Ell
|
|
*
|
|
* This program is free software: you can redistribute it and/or modify
|
|
* it under the terms of the GNU General Public License as published by
|
|
* the Free Software Foundation; either version 3 of the License, or
|
|
* (at your option) any later version.
|
|
*
|
|
* This program is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
* GNU General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU General Public License
|
|
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
*/
|
|
|
|
#ifndef __GIMP_PARALLEL_H__
|
|
#define __GIMP_PARALLEL_H__
|
|
|
|
|
|
typedef void (* GimpParallelRunAsyncFunc) (GimpAsync *async,
|
|
gpointer user_data);
|
|
|
|
typedef void (* GimpParallelDistributeFunc) (gint i,
|
|
gint n,
|
|
gpointer user_data);
|
|
typedef void (* GimpParallelDistributeRangeFunc) (gsize offset,
|
|
gsize size,
|
|
gpointer user_data);
|
|
typedef void (* GimpParallelDistributeAreaFunc) (const GeglRectangle *area,
|
|
gpointer user_data);
|
|
|
|
|
|
void gimp_parallel_init (Gimp *gimp);
|
|
void gimp_parallel_exit (Gimp *gimp);
|
|
|
|
GimpAsync * gimp_parallel_run_async (GimpParallelRunAsyncFunc func,
|
|
gpointer user_data);
|
|
|
|
void gimp_parallel_distribute (gint max_n,
|
|
GimpParallelDistributeFunc func,
|
|
gpointer user_data);
|
|
void gimp_parallel_distribute_range (gsize size,
|
|
gsize min_sub_size,
|
|
GimpParallelDistributeRangeFunc func,
|
|
gpointer user_data);
|
|
void gimp_parallel_distribute_area (const GeglRectangle *area,
|
|
gsize min_sub_area,
|
|
GimpParallelDistributeAreaFunc func,
|
|
gpointer user_data);
|
|
|
|
#ifdef __cplusplus
|
|
|
|
extern "C++"
|
|
{
|
|
|
|
#include <new>
|
|
|
|
template <class ParallelRunAsyncFunc>
|
|
inline GimpAsync *
|
|
gimp_parallel_run_async (ParallelRunAsyncFunc func)
|
|
{
|
|
ParallelRunAsyncFunc *func_copy = g_new (ParallelRunAsyncFunc, 1);
|
|
|
|
new (func_copy) ParallelRunAsyncFunc (func);
|
|
|
|
return gimp_parallel_run_async ([] (GimpAsync *async,
|
|
gpointer user_data)
|
|
{
|
|
ParallelRunAsyncFunc *func_copy =
|
|
(ParallelRunAsyncFunc *) user_data;
|
|
|
|
(*func_copy) (async);
|
|
|
|
func_copy->~ParallelRunAsyncFunc ();
|
|
g_free (func_copy);
|
|
}, func_copy);
|
|
}
|
|
|
|
template <class ParallelDistributeFunc>
|
|
inline void
|
|
gimp_parallel_distribute (gint max_n,
|
|
ParallelDistributeFunc func)
|
|
{
|
|
gimp_parallel_distribute (max_n,
|
|
[] (gint i,
|
|
gint n,
|
|
gpointer user_data)
|
|
{
|
|
ParallelDistributeFunc func_copy (
|
|
*(const ParallelDistributeFunc *) user_data);
|
|
|
|
func_copy (i, n);
|
|
}, &func);
|
|
}
|
|
|
|
template <class ParallelDistributeRangeFunc>
|
|
inline void
|
|
gimp_parallel_distribute_range (gsize size,
|
|
gsize min_sub_size,
|
|
ParallelDistributeRangeFunc func)
|
|
{
|
|
gimp_parallel_distribute_range (size, min_sub_size,
|
|
[] (gsize offset,
|
|
gsize size,
|
|
gpointer user_data)
|
|
{
|
|
ParallelDistributeRangeFunc func_copy (
|
|
*(const ParallelDistributeRangeFunc *) user_data);
|
|
|
|
func_copy (offset, size);
|
|
}, &func);
|
|
}
|
|
|
|
template <class ParallelDistributeAreaFunc>
|
|
inline void
|
|
gimp_parallel_distribute_area (const GeglRectangle *area,
|
|
gsize min_sub_area,
|
|
ParallelDistributeAreaFunc func)
|
|
{
|
|
gimp_parallel_distribute_area (area, min_sub_area,
|
|
[] (const GeglRectangle *area,
|
|
gpointer user_data)
|
|
{
|
|
ParallelDistributeAreaFunc func_copy (
|
|
*(const ParallelDistributeAreaFunc *) user_data);
|
|
|
|
func_copy (area);
|
|
}, &func);
|
|
}
|
|
|
|
}
|
|
|
|
#endif /* __cplusplus */
|
|
|
|
|
|
#endif /* __GIMP_PARALLEL_H__ */
|