flint-sys 0.9.0

Bindings to the FLINT C library
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99

/*
    Copyright (C) 2018 Daniel Schultz

    This file is part of FLINT.

    FLINT is free software: you can redistribute it and/or modify it under
    the terms of the GNU Lesser General Public License (LGPL) as published
    by the Free Software Foundation; either version 3 of the License, or
    (at your option) any later version.  See <https://www.gnu.org/licenses/>.
*/

#ifndef THREAD_POOL_H
#define THREAD_POOL_H

#include "flint.h"

#if FLINT_USES_PTHREAD
#include <pthread.h>
#endif

#ifdef __cplusplus
extern "C" {
#endif

typedef struct
{
#if FLINT_USES_PTHREAD
    pthread_t pth;
    pthread_mutex_t mutex;
    pthread_cond_t sleep1;
    pthread_cond_t sleep2;
#endif
    volatile int idx;
    volatile int available;
    volatile int max_workers;
    void (* fxn)(void *);
    void * fxnarg;
    volatile int working;
    volatile int exit;
} thread_pool_entry_struct;

typedef thread_pool_entry_struct thread_pool_entry_t[1];

typedef struct
{
#if FLINT_USES_CPUSET && FLINT_USES_PTHREAD
    void * original_affinity;
#endif
#if FLINT_USES_PTHREAD
    pthread_mutex_t mutex;
#endif
    thread_pool_entry_struct * tdata;
    slong length;
} thread_pool_struct;

typedef thread_pool_struct thread_pool_t[1];

FLINT_DLL extern thread_pool_t global_thread_pool;
FLINT_DLL extern int global_thread_pool_initialized;

void * thread_pool_idle_loop(void * varg);

void thread_pool_init(thread_pool_t T, slong size);

int thread_pool_set_affinity(thread_pool_t T,
                                                     int * cpus, slong length);

int thread_pool_restore_affinity(thread_pool_t T);

slong thread_pool_get_size(thread_pool_t T);

int thread_pool_set_size(thread_pool_t T, slong new_size);

slong thread_pool_request(thread_pool_t T,
                                    thread_pool_handle * out, slong requested);

void thread_pool_wake(thread_pool_t T, thread_pool_handle i,
                                  int max_workers, void (*f)(void*), void * a);

void thread_pool_wait(thread_pool_t T, thread_pool_handle i);

void thread_pool_give_back(thread_pool_t T, thread_pool_handle i);

void thread_pool_clear(thread_pool_t T);

/* misc internal helpers *****************************************************/

void _thread_pool_distribute_work_2(slong start, slong stop,
                                    slong * Astart, slong * Astop, slong Alen,
                                    slong * Bstart, slong * Bstop, slong FLINT_UNUSED(Blen));

ulong _thread_pool_find_work_2(ulong a, ulong alpha,
                                      ulong b, ulong beta, ulong yn, ulong yd);

#ifdef __cplusplus
}
#endif

#endif