У меня есть эта спецификация:Как синхронизировать две задачи с Micro C OS II?
задачи 0 посылает целые числа (начиная с 1) Задача 1. Задача 1 должна умножить число с -1 и отправить их обратно к задаче 0. Задача 0 должна тогда напечатайте эти номера на консоли. Для связи между заданием 0 и задачей 1 используется один общий адрес ячейки памяти , то есть обе задачи 0 и задача 1 читать и записывать в/из этого места! Сохраните файл как SharedMemory.c. Выполнение программы должно содержать следующие данные: . Посылка: 1 ОФОРМЛЕНИЯ: -1 Отправки: 2 Принимающие: -2 ...
Я написал эту программу, но задачи не правильно синхронизировать, я думаю, что я, возможно, сделал что-то неправильно с семафорами или контекстом переключатель.
я получаю этот выход вместо где число иногда отсчитывает, потому что задачи не synchonize правильно:
Receiving 17
Sending : 16
Receiving -16
Sending : -17
Receiving 17
Sending : 16
Receiving -16
Sending : -17
Receiving 17
Sending : 16
Receiving -16
Sending : -17
Receiving 17
Sending : 16
Receiving -16
Sending : -17
Receiving 17
Sending : 16
Receiving -16
Sending : -17
Receiving 17
Sending : 16
Receiving -16
Sending : -17
Receiving 17
Sending : 16
Receiving -16
Sending : -17
Receiving 17
Sending : 16
Receiving -16
Sending : -17
Receiving 17
Sending : 16
Receiving -16
Sending : -17
Receiving 17
Sending : 16
Receiving -16
Sending : -17
Receiving 17
Sending : 16
Receiving -16
Sending : -17
Receiving 17
Sending : 16
Receiving -16
Sending : -17
Receiving 17
Программа, которую мне нужно изменить в
#include <stdio.h>
#include "includes.h"
#include <string.h>
#define DEBUG 0
/* Definition of Task Stacks */
/* Stack grows from HIGH to LOW memory */
#define TASK_STACKSIZE 2048
OS_STK task1_stk[TASK_STACKSIZE];
OS_STK task2_stk[TASK_STACKSIZE];
OS_STK stat_stk[TASK_STACKSIZE];
OS_EVENT *aSemaphore;
/* Definition of Task Priorities */
#define TASK1_PRIORITY 6 // highest priority
#define TASK2_PRIORITY 7
#define TASK_STAT_PRIORITY 12 // lowest priority
int number = 1;
void handle_button_interrupts(void* context, alt_u32 id)
{
volatile int* edge_capture_ptr = (volatile int*) context;
OSIntEnter();
// Read the edge capture register on the button PIO
//*edge_capture_ptr =
//IORD_ALTERA_AVALON_PIO_EDGE_CAP(BUTTON_PIO_BASE);
OSIntExit();
}
void printStackSize(INT8U prio)
{
INT8U err;
OS_STK_DATA stk_data;
err = OSTaskStkChk(prio, &stk_data);
if (err == OS_NO_ERR)
{
if (DEBUG == 1)
printf("Task Priority %d - Used: %d; Free: %d\n",
prio, stk_data.OSFree, stk_data.OSUsed);
}
else
{
if (DEBUG == 1)
printf("Stack Check Error!\n");
}
}
/* Producer */
void task1(void* pdata)
{
INT8U err;
while (1)
{
char text1[] = "Sending : ";
char text2[] = "Receiving : ";
int i;
OSSemPend(aSemaphore, 0, &err); // Trying to access the key
for (i = 0; i < strlen(text1); i++)
putchar(text1[i]);
printf("%d", number);
putchar('\n');
OSSemPost(aSemaphore); // Releasing the key
OSTimeDlyHMSM(0, 0, 0, 11); // Context Switch to next task
// Task will go to the ready state
// after the specified delay
OSSemPend(aSemaphore, 0, &err); // Trying to access the key
for (i = 0; i < strlen(text1); i++)
putchar(text2[i]);
printf("%d", number);
putchar('\n');
number=-number;
number++;
OSSemPost(aSemaphore); // Releasing the key
OSTimeDlyHMSM(0, 0, 0, 11); // Context Switch to next task
// Task will go to the ready state
// after the specified delay
}
}
/* Consumer */
void task2(void* pdata)
{
INT8U err;
while (1)
{
OSSemPend(aSemaphore, 0, &err); // Trying to access the key
number = -number;
OSSemPost(aSemaphore); // Releasing the key
OSTimeDlyHMSM(0, 0, 0, 4);
}
}
/* Printing Statistics */
void statisticTask(void* pdata)
{
while(1)
{
printStackSize(TASK1_PRIORITY);
printStackSize(TASK2_PRIORITY);
printStackSize(TASK_STAT_PRIORITY);
}
}
/* The main function creates two task and starts multi-tasking */
int main(void)
{
printf("Lab 3 - Handshake\n");
aSemaphore = OSSemCreate(1); // binary semaphore (1 key)
OSTaskCreateExt
(task1, // Pointer to task code
NULL, // Pointer to argument that is
// passed to task
&task1_stk[TASK_STACKSIZE-1], // Pointer to top of task stack
TASK1_PRIORITY, // Desired Task priority
TASK1_PRIORITY, // Task ID
&task1_stk[0], // Pointer to bottom of task stack
TASK_STACKSIZE, // Stacksize
NULL, // Pointer to user supplied memory
// (not needed here)
OS_TASK_OPT_STK_CHK | // Stack Checking enabled
OS_TASK_OPT_STK_CLR // Stack Cleared
);
OSTaskCreateExt
(task2, // Pointer to task code
NULL, // Pointer to argument that is
// passed to task
&task2_stk[TASK_STACKSIZE-1], // Pointer to top of task stack
TASK2_PRIORITY, // Desired Task priority
TASK2_PRIORITY, // Task ID
&task2_stk[0], // Pointer to bottom of task stack
TASK_STACKSIZE, // Stacksize
NULL, // Pointer to user supplied memory
// (not needed here)
OS_TASK_OPT_STK_CHK | // Stack Checking enabled
OS_TASK_OPT_STK_CLR // Stack Cleared
);
if (DEBUG == 1)
{
OSTaskCreateExt
(statisticTask, // Pointer to task code
NULL, // Pointer to argument that is
// passed to task
&stat_stk[TASK_STACKSIZE-1], // Pointer to top of task stack
TASK_STAT_PRIORITY, // Desired Task priority
TASK_STAT_PRIORITY, // Task ID
&stat_stk[0], // Pointer to bottom of task stack
TASK_STACKSIZE, // Stacksize
NULL, // Pointer to user supplied memory
// (not needed here)
OS_TASK_OPT_STK_CHK | // Stack Checking enabled
OS_TASK_OPT_STK_CLR // Stack Cleared
);
}
OSStart();
return 0;
}
Можете ли вы мне помочь ?
Почему вы делаете Сны? SemPend должен поставить задачу в состояние ожидания. Вы пытались изменить приоритеты задач? – LostBoy