time_t tv_sec; // значение секунд
long tv_nsec; // значение наносекунд
}При успешном выполнении функция
sched_rr_get_interval()Две другие функции, часто удобные для работы со структурой
timespec
#include <time.h>
void nsec2timespec(struct timespec *timespec_p, _uint64 nsec);— это преобразование интервала, выраженного в наносекундах (nsec), в структуру
timespectimespec_p
#include <time.h>
_uint64 timespec2nsec(const struct timespec* ts);— это преобразование структуры timespec в значение, выраженное в наносекундах (это функция из native API QNX).
3. Спорадическая диспетчеризация — это гораздо более развитая форма «вытесняющей многозадачности», численные характеристики которой (время кванта, численные значения приоритетов и др.) могут детально параметризироваться и даже динамически изменяться по ходу выполнения. Подробнее спорадическая диспетчеризация рассмотрена далее.
Часто задают вопрос: «А как много потоков целесообразно делать? Не сколько снижается эффективность многопоточной программы за счет диспетчеризации потоков?» С другой стороны, в литературе часто встречаются (достаточно голословные, на качественном уровне) утверждения, что многопоточная программа будет заметно уступать в фиктивности своему последовательному (в одном потоке) эквиваленту. Проверим это на реальной задаче:
#include <stdlib.h>
#include <stdio.h>
#include <iostream.h>
#include <unistd.h>
#include <limits.h>
#include <pthread.h>
#include <inttypes.h>
#include <sys/neutrino.h>
#include <sys/syspage.h>
#include <errno.h>
#include <math.h>
// преобразование процессорных циклов в миллисекунды:
static double cycle2milisec(uint64_t ccl) {
const static double s2m = 1.E+3;
// это скорость процессора
const static uint64_t
cps = SYSPAGE_ENTRY(qtime)->cycles_per_sec;
return (double)ccl * s2m / (double)cps;
}
static int nsingl = 1;
// рабочая функция, которая имитирует вычисления:
void workproc(int how) {
const int msingl = 30000;
for (int j = 0; j < how; j++)
for (uint64_t i=0; i < msingl * nsingl; i++)
i = (i + 1) - 1;
}
static pthread_barrier_t bstart, bfinish;
struct interv { uint64_t s, f; };
interv *trtime;
void* threadfunc(void* data) {
// все потоки после создания должны "застрять" на входном
// барьере, чтобы потом одновременно "сорваться" в исполнение
pthread_barrier_wait(&bstart);
int id = pthread_self() - 2;
trtime[id].s = ClockCycles();
workproc((int)data);
trtime[id].f = ClockCycles();
pthread_barrier_wait(&bfinish);
return NULL;
}
int main(int argc, char *argv[]) {
// здесь только обработка многочисленных ключей...
int opt, val, nthr = 1, nall = SHRT_MAX;
while ((opt = getopt(argc, argv, "t:n:p:a:")) != -1) {
switch(opt) {
case 't':
if (sscanf(optarg, "%i", &val) != 1)
perror("parse command line failed"), exit(EXIT_FAILURE);
if (val > 0 && val <= SHRT_MAX) nthr = val;
break;
case 'p':
if (sscanf(optarg, "%i", &val) != 1)
perror("parse command line failed"), exit(EXIT_FAILURE);
if (val != getprio(0))
if (setprio(0, val) == -1)
perror("priority isn't a valid"), exit(EXIT_FAILURE);
break;
case 'n':
if (sscanf(optarg, "%i", &val) != 1)
perror("parse command line failed"), exit(EXIT_FAILURE);
if (val > 0)nsingl *= val;
break;
case 'a':
if (sscanf(optarg, "%i", &val) != 1)
perror("parse command line failed"), exit(EXIT_FAILURE);