static void futex_wake(unsigned *uaddr, unsigned val);
#endif
+#ifndef _MSC_VER
static void xbt_parmap_busy_master_wait(xbt_parmap_t parmap);
static void xbt_parmap_busy_worker_signal(xbt_parmap_t parmap);
static void xbt_parmap_busy_master_signal(xbt_parmap_t parmap);
static void xbt_parmap_busy_worker_wait(xbt_parmap_t parmap, unsigned round);
+#endif
#ifdef HAVE_MC
static void xbt_parmap_mc_work(xbt_parmap_t parmap, int worker_id);
XBT_DEBUG("Create new parmap (%u workers)", num_workers);
/* Initialize the thread pool data structure */
- xbt_parmap_t parmap = xbt_new0(s_xbt_parmap_t, 1);
+ xbt_parmap_t parmap = new s_xbt_parmap_t();
parmap->workers = xbt_new(xbt_os_thread_t, num_workers);
parmap->num_workers = num_workers;
XBT_DEBUG("Create new parmap (%u workers)", num_workers);
/* Initialize the thread pool data structure */
- xbt_parmap_t parmap = xbt_new0(s_xbt_parmap_t, 1);
+ xbt_parmap_t parmap = new s_xbt_parmap_t();
parmap->workers = xbt_new(xbt_os_thread_t, num_workers);
parmap->num_workers = num_workers;
xbt_os_mutex_destroy(parmap->done_mutex);
xbt_free(parmap->workers);
- xbt_free(parmap);
+ delete parmap;
}
/**
#endif
case XBT_PARMAP_BUSY_WAIT:
+#ifndef _MSC_VER
parmap->master_wait_f = xbt_parmap_busy_master_wait;
parmap->worker_signal_f = xbt_parmap_busy_worker_signal;
parmap->master_signal_f = xbt_parmap_busy_master_signal;
xbt_os_cond_destroy(parmap->done_cond);
xbt_os_mutex_destroy(parmap->done_mutex);
break;
+#else
+ xbt_die("Busy waiting not implemented on Windows yet.");
+#endif
case XBT_PARMAP_DEFAULT:
THROW_IMPOSSIBLE;
}
#endif
+#ifndef _MSC_VER
/**
* \brief Starts the parmap: waits for all workers to be ready and returns.
*
xbt_os_thread_yield();
}
}
+#endif /* ! _MSC_VER */