#include <stdio.h>
#include<time.h>
#define TRUE 1
#define FALSE 0
#define MAX_TIMERS ... 最大时钟数量
typedef timerval TIME; 定义时间类型
#define VERY_LONG_TIME ... 最大时间长度
struct timer {
int inuse; 时钟是否可用
TIME time; 定时时间长度
char *event; 是否超时
} timers[MAX_TIMERS]; /* set of timers */
void
timers_init() {
struct timer *t;
for (t=timers;t<&timers[MAX_TIMERS];t++)
t->inuse = FALSE;
}
volatile TIME time_now
struct timer *timer_next = NULL;/* timer we expect to run down next */
TIME time_timer_set; /* time when physical timer was set */
//取消一个定时器
void timer_undeclare(struct timer *t)
{
disable_interrupts();
if(!t->inuse)
{
enable_interrupts();
return ;
}
t->inuse=0;
if(t==timer_next)
{
if(time(&time_now)<0)
perror("time error");
timers_update(time_now-time_timer_set);
if(timer_next)
{
start_physical_timer(&timer_next->time);
time_timer_set=time_now;
}
}
enable_interrupts();
}
//更新定时器表时间
void timers_update(time_t time)
{
static struct timer timer_last={
0,
{},
NULL
};
timer_last.time.tv_sec=10;
struct timer *t;
timer_next=&timer_last;
for(t=timers;t<&timers[MAX_TIMERS];t++)
{
if(t->inuse)
{
if(time<t->time.tv_sec){
t->time.tv_sec-=time;
if(t->time.tv_sec<\
timer_next->time.tv_sec)
timer_next=t;
}else
{
*(t->event)=1;
t->inuse=0;
}
}
}
if(!timer_next->inuse)timer_next=0;
}
struct timer * timer_declare(TIME *ti,char *event)
{
struct timer *t;
disable_interrupts();
for(t=timers;t<&timers[MAX_TIMERS];t++)
{
if(!t->inuse)break;
}
if(t==&timers[MAX_TIMERS])
{
enable_interrupts();
return 0;
}
t->event=event;
t->time.tv_sec=ti->tv_sec;
t->time.tv_usec=ti->tv_usec;
if(!timer_next)
{
if(time(&time_now)<0)
perror("time() error");
time_timer_set=time_now;
start_physical_timer(&((timer_next=t)->time));
}else if((ti->tv_sec+time_now)<(\
timer_next->time.tv_sec+time_timer_set))
{
if(time(&time_now)<0)
perror("time error");
timers_update(time_now-time_timer_set);
time_timer_set=time_now;
start_physical_timer(&((timer_next=t)->time));
}else
{
}
t->inuse=1;
enable_interrupts();
return t;
}
//定时器中断处理函数
void timer_interrupt_hander(int signo)
{
printf("interrupt_hander\n");
if(time(&time_now)<0)
perror("time() error");
timers_update(time_now-time_timer_set);
if(timer_next)
{
time_timer_set=time_now;
start_physical_timer(&timer_next->time);
}
}
//失效定时器中断
void disable_interrupts()
{sigset_t new_mask;
sigemptyset(&new_mask);
sigaddset(&new_mask,SIGALRM);
if(sigprocmask(SIG_BLOCK,&new_mask,NULL)<0)
perror("SIG_BLOCK error");
}
//使能定时器中断
void enable_interrupts()
{
sigset_t new_mask;
sigemptyset(&new_mask);
sigaddset(&new_mask,SIGALRM);
if(sigprocmask(SIG_UNBLOCK,&new_mask,NULL)<0)
perror("SIG_UNBLOCK error");
}
//开启一个定时器工作
void start_physical_timer(TIME* time)
{
if(signal(SIGALRM,timer_interrupt_hander)==SIG_ERR)
perror("signal error");
struct itimerval new_value;
sigset_t zero_mask;
sigemptyset(&zero_mask);
new_value.it_value.tv_sec=time->tv_sec;
new_value.it_value.tv_usec=time->tv_usec;
new_value.it_interval.tv_sec=0;
new_value.it_interval.tv_usec=0;
setitimer(ITIMER_REAL,&new_value,NULL);
sigsuspend(&zero_mask);
}
#include<stdio.h>
#include<signal.h>
#include"multtime.h"
#include<stdlib.h>
#include<unistd.h>
int main()
{
pid_t pid;
TIME time1,time2,time3;
time1.tv_sec=6;
time1.tv_usec=0;
time2.tv_sec=4;
time2.tv_usec=0;
time3.tv_sec=2;
time3.tv_usec=0;
timer_init();
if((pid=fork())<0)
{
perror("fork() error");
}
else if(pid==0)
{
printf("child 1\n");
timer_undeclare(timer_declare(&time1,0));
}
else
{
if((pid=fork())<0)
{
perror("fork error");
}
else if(pid==0)
{
printf("child 2\n");
timer_undeclare(timer_declare(&time3,0));
}
else
{
printf("parent\n");
timer_undeclare(timer_declare(&time2,0));
}
}
exit(0);
}
parent child 2 child 1 interrupt_hander interrupt_hander interrupt_hander
机械节能产品生产企业官网模板...
大气智能家居家具装修装饰类企业通用网站模板...
礼品公司网站模板
宽屏简约大气婚纱摄影影楼模板...
蓝白WAP手机综合医院类整站源码(独立后台)...苏ICP备2024110244号-2 苏公网安备32050702011978号 增值电信业务经营许可证编号:苏B2-20251499 | Copyright 2018 - 2025 源码网商城 (www.ymwmall.com) 版权所有