Function th_worker

numexpr3/module.cpp:35–161

Do the worker job for a certain thread

// Do the worker job for a certain thread
void* th_worker(void *tidptr) {
    int tid = *(int *)tidptr;
    // Parameters for threads
    npy_intp start;
    npy_intp vlen;
    npy_intp task_size;
    NpyIter* iter;
    NumExprObject* neObj;

    int* pc_error;
    int ret;
    npy_intp istart, iend;
    char** errorMessage;

    while(1) {
        
        if( tid == 0 ) {
            gs.init_sentinels_done = 0; // sentinels have to be initialised yet
        }

        // Meeting point for all threads (wait for initialization)
        CHECK_END_COND;
        pthread_mutex_lock(&gs.count_threads_mutex);
        if( gs.count_threads < gs.n_thread ) {
            gs.count_threads++;
            // printf( "Count threads start %d\n", gs.count_threads );
            do {
                pthread_cond_wait(&gs.count_threads_cv, &gs.count_threads_mutex);
            } while (gs.barrier_passed == BARRIER_HALT);
        }
        else { // Every thread is ready, go...
            gs.barrier_passed = BARRIER_PASS;
            pthread_cond_broadcast(&gs.count_threads_cv);
        }
        pthread_mutex_unlock(&gs.count_threads_mutex);
        // Get parameters for this thread before entering the main loop 
        start = gs.start;
        vlen = gs.vlen;
        task_size = gs.task_size;
        neObj = &gs.params[tid];
        pc_error = gs.pc_error;

        errorMessage = gs.errorMessage;

        // Loop over blocks
        CHECK_END_COND;
        pthread_mutex_lock(&gs.count_mutex);
        if( !gs.init_sentinels_done ) {
            // Set sentinels and other global variables
            gs.gindex = start;
            istart = gs.gindex;
            iend = istart + task_size;
            if (iend > vlen) {
                iend = vlen;
            }
            gs.init_sentinels_done = 1;  // sentinels have been initialised
            gs.giveup = 0;            // no giveup initially
        } else {