嵌入式操作系统内核原理和开发(多线程轮转).doc
文本预览下载声明
嵌入式操作系统内核原理和开发（多线程轮转）
之前我们也谈到了线程创建，基本上简单的系统就可以跑起来了，但是还没有到多线程运行的地步。所以，我们下面试图所要做的工作就是创建更多的线程，让更多的线程运行起来。为了做好这一点，首先我们需要对task_init重新修整一下，
[cpp] view plaincopy
void task_init(int index, UINT32 data[], int size, void (*func)())
{
UINT32 unit = size;
memset((void*)data, 0, size * sizeof(UINT32));
data[unit -1] = (UINT32) func;
data[unit -2] = 0;
data[unit -3] = 0;
data[unit -4] = 0;
data[unit -5] = 0;
data[unit -6] = 0;
data[unit -7] = 0;
data[unit -8] = 0;
data[unit -9] = 0;
data[unit -10] = (UINT32) data[unit - 9];
new[index] = (UINT32) data[unit -10];
}
这是一个创建线程的函数，有堆栈、大小、函数入口。那么，我们的函数什么时候创建呢，其实就是在系统的开始位置就可以，
[cpp] view plaincopy
void set_all_task()
{
int index;
for(index = 0; index THREAD_MAX_NUMBER; index ++)
task_init(index, task_stack[index], STACK_LENGTH, hello);
}
既然任务创建没有问题，那么下面就会涉及到简单轮转的问题。其实我们的方法特别简单，就是根据current_thread_id叠加，每一个thread都有自己的运转机会。代码如下所示，
[cpp] view plaincopy
void signal_handler(int m)
{
current_thread_id = current_thread_id % THREAD_MAX_NUMBER;
if(0 == quit[current_thread_id])
{
swap(old, new[current_thread_id]);
}
printf(count = %d in main!\n\n, count ++);
current_thread_id ++;
}
当然，为了要实现真正的多线程运行，我们还要保证线程始终在运行。要达到这一点也不是很复杂，只需要把子函数设计为while（1）即可，
[cpp] view plaincopy
void hello()
{
while(1) {
printf(id = %i, count = %d in thread!\n,current_thread_id, count ++);
swap(new[current_thread_id], old);
printf(id = %i, count = %d in thread!\n,current_thread_id, count ++);
swap(new[current_thread_id], old);
}
}
基本上要做到以上几点就可以实现了，最后给出完整的代码，大家可以在linux系统好好试试这个代码。
[cpp] view plaincopy
#include stdio.h
#include time.h
#include stdlib.h
#include signal.h
#include assert.h
#include sys/ti
显示全部