Function batch_resolve_worker

src/semantic/semantic.c:669–703

}

static void batch_resolve_worker(int worker_id, void *ctx_ptr) {
    (void)worker_id;
    batch_resolve_ctx_t *bc = ctx_ptr;
    /* Per-worker scratch for unique-per-doc tracking */
    int local_seen_cap = CBM_SEM_SEEN_INIT_CAP;
    int *seen = malloc((size_t)local_seen_cap * sizeof(int));
    if (!seen) {
        return;
    }

    while (true) {
        int start =
            atomic_fetch_add_explicit(&bc->next_idx, CBM_SEM_RESOLVE_CHUNK, memory_order_relaxed);
        if (start >= bc->doc_count) {
            break;
        }
        int end = start + CBM_SEM_RESOLVE_CHUNK;
        if (end > bc->doc_count) {
            end = bc->doc_count;
        }
        for (int d = start; d < end; d++) {
            int count = bc->token_counts[d];
            if (count > local_seen_cap) {
                int *grown = realloc(seen, (size_t)count * sizeof(int));
                if (!grown) {
                    continue;
                }
                seen = grown;
                local_seen_cap = count;
            }
            batch_resolve_one_doc(bc, d, seen);
        }
    }
    free(seen);
}

void cbm_sem_corpus_add_docs_batch(cbm_sem_corpus_t *corpus, char **all_tokens,
                                   const int *token_counts, int doc_count, int max_tokens_per_doc) {