#include "stdioh"
#include "stdlibh"
#include "stringh"
struct PCB {
char NAME[10]; /进程名/
int ROUND; /进程轮转时间片/
int REACHTIME; /进程到达时间/
int CPUTIME; /进程占用CPU时间/
int COUNT; /计数器/
int NEEDTIME; /进程完成还要的CPU时间/
char STATE; /进程的状态/
struct PCB NEXT; /链指针/
};
struct LINK { /PCB的链结构/
struct PCB RUN; /当前运行进程指针/
struct PCB READY; /就绪队列头指针/
struct PCB TAIL; /就绪队列尾指针/
struct PCB FINISH; /完成队列头指针/
};
void INIT(LINK ); /对PCB的链结构初始化/
void INSERT(LINK ); /将执行了一个单位时间片数且还未完成的进程的PCB插到就绪队列的队尾/
void FIRSTIN(LINK ); /将就绪队列中的第一个进程投入运行/
void PRINT(LINK ); /打印每执行一个时间片后的所有进程的状态/
void PR(PCB ); /打印一个进程的状态/
int CREATE(LINK ,int); /创建新的进程/
void ROUNDSCH(LINK ); /按时间片轮转法调度进程/
void main() {
LINK pcbs;
int i;
INIT(&pcbs);
i=0;
printf("创建5个进程\n\n");
while(i<5) {
if(CREATE(&pcbs,i+1)==1) {
printf("进程已创建\n\n");
i++;
}
else
printf("进程创建失败\n\n");
}
FIRSTIN(&pcbs);
ROUNDSCH(&pcbs);
}
void ROUNDSCH(LINK p) {
PCB pcb;
while(p->RUN!=NULL) {
pcb=(PCB )malloc(sizeof(PCB));
strcpy(pcb->NAME,p->RUN->NAME);
pcb->ROUND=p->RUN->ROUND;
pcb->REACHTIME=p->RUN->REACHTIME;
pcb->CPUTIME=p->RUN->CPUTIME;
pcb->COUNT=p->RUN->COUNT;
pcb->NEEDTIME=p->RUN->NEEDTIME;
pcb->STATE=p->RUN->STATE;
pcb->NEXT=p->RUN->NEXT;
pcb->CPUTIME++;
pcb->NEEDTIME--;
pcb->COUNT++;
if(pcb->NEEDTIME==0) {
pcb->NEXT=p->FINISH->NEXT;
p->FINISH->NEXT=pcb;
pcb->STATE='F';
p->RUN=NULL;
if(p->READY!=p->TAIL)
FIRSTIN(p);
}
else {
p->RUN=pcb;
if(pcb->COUNT==pcb->ROUND) {
pcb->COUNT=0;
if(p->READY!=p->TAIL) {
pcb->STATE='W';
INSERT(p);
FIRSTIN(p);
}
}
}
PRINT(p);
}
}
void INIT(LINK p) {
p->RUN=NULL;
p->TAIL=p->READY=(PCB )malloc(sizeof(PCB));
p->READY->NEXT=NULL;
p->FINISH=(PCB )malloc(sizeof(PCB));
p->FINISH->NEXT=NULL;
}
int CREATE(LINK p,int n) {
PCB pcb,q;
pcb=(PCB )malloc(sizeof(PCB));
flushall();
printf("请输入第%d个进程的名称:\n",n);
gets(pcb->NAME);
printf("请输入第%d个进程的轮转时间片数:\n",n);
scanf("%d",&(pcb->ROUND));
printf("请输入第%d个进程的到达时间:\n",n);
scanf("%d",&(pcb->REACHTIME));
pcb->CPUTIME=0;
pcb->COUNT=0;
printf("请输入第%d个进程需运行的时间片数:\n",n);
scanf("%d",&(pcb->NEEDTIME));
pcb->STATE='W';
pcb->NEXT=NULL;
if(strcmp(pcb->NAME,"")==0||pcb->ROUND<=0||pcb->NEEDTIME<=0) /输入错误/
return 0;
q=p->READY;
while(q->NEXT!=NULL&&q->NEXT->REACHTIME<=pcb->REACHTIME)
q=q->NEXT;
pcb->NEXT=q->NEXT;
q->NEXT=pcb;
if(pcb->NEXT==NULL)
p->TAIL=pcb;
return 1;
}
void FIRSTIN(LINK p) {
PCB q;
q=p->READY->NEXT;
p->READY->NEXT=q->NEXT;
q->NEXT=NULL;
if(p->READY->NEXT==NULL)
p->TAIL=p->READY;
q->STATE='R';
p->RUN=q;
}
void INSERT(LINK p) {
PCB pcb;
pcb=(PCB )malloc(sizeof(PCB));
strcpy(pcb->NAME,p->RUN->NAME);
pcb->ROUND=p->RUN->ROUND;
pcb->REACHTIME=p->RUN->REACHTIME;
pcb->CPUTIME=p->RUN->CPUTIME;
pcb->COUNT=p->RUN->COUNT;
pcb->NEEDTIME=p->RUN->NEEDTIME;
pcb->STATE=p->RUN->STATE;
pcb->NEXT=p->RUN->NEXT;
p->TAIL->NEXT=pcb;
p->TAIL=pcb;
p->RUN=NULL;
pcb->STATE='W';
}
void PRINT(LINK p) {
PCB pcb;
printf("执行一个时间片后的所有进程的状态:\n\n");
if(p->RUN!=NULL)
PR(p->RUN);
if(p->READY!=p->TAIL) {
pcb=p->READY->NEXT;
while(pcb!=NULL) {
PR(pcb);
pcb=pcb->NEXT;
}
}
pcb=p->FINISH->NEXT;
while(pcb!=NULL) {
PR(pcb);
pcb=pcb->NEXT;
}
}
void PR(PCB p) {
printf("进程名:%s\n",p->NAME);
printf("进程轮转时间片:%d\n",p->ROUND);
printf("进程到达时间:%d\n",p->REACHTIME);
printf("进程占用CPU时间:%d\n",p->CPUTIME);
printf("计数器:%d\n",p->COUNT);
printf("进程完成还要的CPU时间:%d\n",p->NEEDTIME);
printf("进程的状态:%c\n\n",p->STATE);
}
”转换被检测到,转换正在杀死其他步骤“ 这并不是一个错误,这只是一个提示信息。
意思是 你这个转换有几个并行执行的步骤 ,其中有个步骤报错了,结果整个转换失败 进而杀死其他正常执行的步骤。
你需要仔细找日志 找到发生错误的那个步骤及其 错误日志信息
如果你正在学习kettle 可以参考我写的:>
使用资源库(repository)登录时,默认的用户名和密码是admin/admin
当job是存放在资源库(一般资源库都使用数据库)中时,使用Kitchenbat执行job时,需使用如下的命令行:
Kitchenbat /rep kettle /user admin /pass admin /job job名
当job没有存放在资源库而存放在文件系统时,使用Kitchenbat执行job时,需使用如下的命令行:
Kitchenbat /norep /file user-transfer-jobkjb
可以使用命令行执行job后,就可以使用windows或linux的任务调度来定时执行任务了
在一开始使用命令行方式执行job时,总是报如下的错误,琢磨了好长时间总算整明白正确的方式了。
将安装包pdi-ce-5401-130\data-integration\ui目录下的所有文件拷贝到源码包pentaho-kettle-5401-R\ui目录下,即可解决~~
1 单数据源输入,直接用sql 做连接
2 多数据源输入,(可能是文本或是两个以上源数据库),用database join *** 作
3 三个表以上的多字段输出
2 Kettle的数据库连接模式
Kettle的数据库连接是一个步骤里面控制一个单数据库连接,所以kettle的连接有数据库连接池,你可以在指定的数据库连接里面指定一开始连接池里面放多少个数据库连接,在创建数据库连接的时候就有Pooling 选项卡,里面可以指定最大连接数和初始连接数,这可以一定程度上提高速度
以上就是关于kettle 正则表达式 获取文件名全部的内容,包括:kettle 正则表达式 获取文件名、kettle抽取数据时提示转换被检测到,转换正在杀死其他步骤是什么错误、求助,kettle使用kitchen命令的时候报错等相关内容解答,如果想了解更多相关内容,可以关注我们,你们的支持是我们更新的动力!
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)