Searched refs:job_count (Results 1 – 4 of 4) sorted by relevance
| /third_party/glib/gio/ |
| D | gthreadedsocketservice.c | 57 gint job_count; member
71 G_LOCK_DEFINE_STATIC(job_count);
99 G_LOCK (job_count); in g_threaded_socket_service_func()
100 if (data->service->priv->job_count-- == data->service->priv->max_threads) in g_threaded_socket_service_func()
102 G_UNLOCK (job_count); in g_threaded_socket_service_func()
123 G_LOCK (job_count); in g_threaded_socket_service_incoming()
124 if (++threaded->priv->job_count == threaded->priv->max_threads) in g_threaded_socket_service_incoming()
126 G_UNLOCK (job_count); in g_threaded_socket_service_incoming()
|
| /third_party/ffmpeg/libavcodec/ |
| D | pthread_slice.c | 95 …execute(AVCodecContext *avctx, action_func* func, void *arg, int *ret, int job_count, int job_size) in thread_execute() argument
100 return avcodec_default_execute(avctx, func, arg, ret, job_count, job_size); in thread_execute()
102 if (job_count <= 0) in thread_execute()
110 avpriv_slicethread_execute(c->thread, job_count, !!c->mainfunc ); in thread_execute()
114 …int thread_execute2(AVCodecContext *avctx, action_func2* func2, void *arg, int *ret, int job_count) in thread_execute2() argument
118 return thread_execute(avctx, NULL, arg, ret, job_count, 0); in thread_execute2()
121 …VCodecContext *avctx, action_func2* func2, main_func *mainfunc, void *arg, int *ret, int job_count) in ff_slice_thread_execute_with_mainfunc() argument
126 return thread_execute(avctx, NULL, arg, ret, job_count, 0); in ff_slice_thread_execute_with_mainfunc()
|
| D | thread.h | 141 int (*main_func)(AVCodecContext *c), void *arg, int *ret, int job_count);
|
| /third_party/python/Lib/test/ |
| D | test_concurrent_futures.py | 1022 job_count = 15 * executor._max_workers
1024 for _ in range(job_count):
1027 for _ in range(job_count):
|