Reuse threads by using GLib's threadpool

kleisauke · kleisauke · commit 80e0cc3d127b · 2021-05-03T13:21:45.000+02:00
diff --git a/libvips/include/vips/internal.h b/libvips/include/vips/internal.h
@@ -111,6 +111,7 @@ extern gboolean vips__cache_trace;
 extern int vips__n_active_threads;
 
 void vips__threadpool_init( void );
+void vips__threadpool_shutdown( void );
 
 void vips__cache_init( void );
 
diff --git a/libvips/include/vips/threadpool.h b/libvips/include/vips/threadpool.h
@@ -5,6 +5,8 @@
  * 17/3/10
  * 	- from threadgroup
  * 	- rework with a simpler distributed work allocation model
+ * 02/02/20 kleisauke
+ * 	- reuse threads by using GLib's threadpool
  */
 
 /*
@@ -130,6 +132,7 @@ typedef int (*VipsThreadpoolWorkFn)( VipsThreadState *state, void *a );
  */
 typedef int (*VipsThreadpoolProgressFn)( void *a );
 
+int vips_threadpool_push( const char *name, GFunc func, gpointer data );
 int vips_threadpool_run( VipsImage *im, 
 	VipsThreadStartFn start, 
 	VipsThreadpoolAllocateFn allocate, 
diff --git a/libvips/iofuncs/init.c b/libvips/iofuncs/init.c
@@ -665,7 +665,7 @@ vips_leak( void )
  *
  * This function needs to be called when a thread that has been using vips
  * exits. It is called for you by vips_shutdown() and for any threads created
- * by vips_g_thread_new(). 
+ * within the #VipsThreadPool. 
  *
  * You will need to call it from threads created in
  * other ways or there will be memory leaks. If you do not call it, vips 
@@ -719,6 +719,8 @@ vips_shutdown( void )
 
 	vips__thread_profile_stop();
 
+	vips__threadpool_shutdown();
+
 #ifdef HAVE_GSF
 	gsf_shutdown(); 
 #endif /*HAVE_GSF*/
diff --git a/libvips/iofuncs/threadpool.c b/libvips/iofuncs/threadpool.c
