*/
void xbt_parmap_apply(xbt_parmap_t parmap, void_f_pvoid_t fun, xbt_dynar_t data)
{
- /* Assign resources to worker threads*/
+ /* Assign resources to worker threads */
parmap->fun = fun;
parmap->data = data;
parmap->index = 0;
return NULL;
}
-/**
- * \brief Returns the worker id of the current thread.
- * \param parmap a parmap
- * \return the worker id
- */
-unsigned long xbt_parmap_get_worker_id(xbt_parmap_t parmap)
-{
- return (unsigned long) xbt_os_thread_get_extra_data();
-}
-
/**
* \brief Main function of a worker thread.
* \param arg the parmap
xbt_os_thread_set_extra_data((void*) (unsigned long) worker_id);
XBT_DEBUG("New worker thread created (%u)", worker_id);
-
+
/* Worker's main loop */
while (1) {
xbt_parmap_wait(parmap);
/* Create the parallel map */
parmap = xbt_parmap_new(10);
- for(j = 0; j < 100; j++) {
+ for (j = 0; j < 100; j++) {
xbt_dynar_push_as(data, void *, (void *)j);
}