Explication détaillée des problèmes de file d'attente en langage C sous Linux-exploitation et maintenance Linux-php.cn

Explication détaillée des problèmes de file d'attente en langage C sous Linux

黄舟

Libérer： 2017-06-07 09:56:05

original

1812 Les gens l'ont consulté

Récemment, j'ai écrit un programme qui utilisait le fonctionnement de file d'attente du langage C sous le système Linux, j'ai donc eu le problème suivant
Voici le code de la file d'attente :
Ce fichier d'en-tête de file d'attente <.>

extern struct pqueue Que;

/*构造一个空队列*/
extern pQueue *InitQueue();

/*销毁一个队列*/
extern void DestroyQueue(pQueue *pqueue);

/*清空一个队列*/
extern void ClearQueue(pQueue *pqueue);

/*判断队列是否为空*/
extern int IsEmpty(pQueue *pqueue);

/*返回队列大小*/
extern int GetSize(pQueue *pqueue);

/*返回队头元素*/
extern PNode GetFront(pQueue *pqueue,char *pitem);

/*返回队尾元素*/
extern PNode GetRear(pQueue *pqueue,char *pitem);

/*将新元素入队*/
extern PNode InQueue(pQueue *pqueue,char *pitem);

/*队头元素出队*/
extern PNode OutQueue(pQueue *pqueue,char *pitem);

Copier après la connexion

Ce qui suit est la fonction Queue

struct pqueue Queue;		



	/*构造一个空队列*/

	pQueue *InitQueue()

	{

		pQueue *pqueue = (pQueue *)malloc(sizeof(Queue));

		if(pqueue!=NULL)

		{

			pqueue->front = NULL;

			pqueue->rear = NULL;

			pqueue->size = 0;

		}

		return pqueue;

	}



	/*销毁一个队列*/

	void DestroyQueue(pQueue *pqueue)

	{

		if(IsEmpty(pqueue)!=1)

			ClearQueue(pqueue);

		free(pqueue);

	}

	

	/*清空一个队列*/

	void ClearQueue(pQueue *pqueue)

	{

		while(IsEmpty(pqueue)!=1)

		{

			OutQueue(pqueue,NULL);

		}

	

	}

	

	/*判断队列是否为空*/

	int IsEmpty(pQueue *pqueue)

	{

		if(pqueue->front==NULL&&pqueue->rear==NULL&&pqueue->size==0)

			return 1;

		else

			return 0;

	}

	

	/*返回队列大小*/

	int GetSize(pQueue *pqueue)

	{

		return pqueue->size;

	}

	

	/*返回队头元素*/

	PNode GetFront(pQueue *pqueue,char *pitem)

	{

		if(IsEmpty(pqueue)!=1)

		{

			//pitem = pqueue->front->data;

		strcpy(pitem,pqueue->front->data);

		}

		return pqueue->front;

	}

	

	/*返回队尾元素*/

	

	PNode GetRear(pQueue *pqueue,char *pitem)

	{

		if(IsEmpty(pqueue)!=1)

		{

			//pitem = pqueue->rear->data;

		strcpy(pitem,pqueue->rear->data);

		}

		return pqueue->rear;

	}

	

	/*将新元素入队*/

	PNode InQueue(pQueue *pqueue,char *pitem)

	{

	//DBG0_PR("dbg QueueIn front=%d, rear=%d, count=%d\n", pqueue->front, pqueue->rear, pqueue->size);

		PNode pnode = (PNode)malloc(sizeof(Node));

		if(pnode != NULL)

		{

			strcpy(pnode->data, pitem);

			pnode->next = NULL;

	

			if(IsEmpty(pqueue))

			{

				pqueue->front = pnode;

			}

			else

			{

				pqueue->rear->next = pnode;

			}

			pqueue->rear = pnode;

			pqueue->size++;

		}

		return pnode;

	}

	

	/*队头元素出队*/

	PNode OutQueue(pQueue *pqueue,char *pitem)

	{

		PNode pnode = pqueue->front;

		if(IsEmpty(pqueue)!=1 && pnode!=NULL)

		{

			if(pitem!=NULL)

				strcpy(pitem,pnode->data);

			//pitem = pnode->data;

			pqueue->front = pnode->next;

			free(pnode);

			pqueue->size = pqueue->size - 1;

			if(pqueue->size == 0 ){

				pqueue->rear = NULL;

			}

		}

		return pqueue->front;

	}

Copier après la connexion

Le problème est décrit comme suit lors de l'utilisation de la sortie de la file d'attente :

Pour Pour l'opération de mise en file d'attente, la taille de la file d'attente est de 1, et pour l'opération de retrait de la file d'attente, l'opération de taille de file d'attente est de 0, puis le programme revient en arrière pour déterminer la taille de la file d'attente. La valeur de la taille devient 393216. Je ne sais pas ce qui s'est passé après l'avoir modifiée pour un. ça fait longtemps.

Le message d'erreur est comme ça

*** glibc detected ***      double free or corruption (!prev):

Copier après la connexion

Si une crevette l'a vu, répondez-moi ou donnez-moi quelques idées. J'ai l'impression d'être mort. fin. Merci! ! ! !

Répondre à la discussion (solution)

Commentez une partie du code Si le problème disparaît, le problème réside dans le. code commenté.

Imprimez la valeur de la taille en temps réel pour voir à quelle étape l'exception s'est produite

Pour référence seulement

#ifndef __PQUEUE_H__
#define __PQUEUE_H__

#include <stdio.h>
#include <stdlib.h>
#include <string.h>

#define MAX_DATA_SIZE 256

typedef struct _node {
	char data[MAX_DATA_SIZE];
	struct _node* next;
} Node, *pNode;

typedef struct __pqueue {
	pNode front;
	pNode rear;
	int size;
} Queue, *pQueue;

/*构造一个空队列*/
extern pQueue InitQueue();

/*销毁一个队列*/
extern void DestroyQueue(pQueue pqueue);

/*清空一个队列*/
extern void ClearQueue(pQueue pqueue);

/*判断队列是否为空*/
extern int IsEmpty(pQueue pqueue);

/*返回队列大小*/
extern int GetSize(pQueue pqueue);

/*返回队头元素*/
extern int GetFront(pQueue pqueue, char *pitem);

/*返回队尾元素*/
extern int GetRear(pQueue pqueue, char *pitem);

/*将新元素入队*/
extern int InQueue(pQueue pqueue, char *pitem);

/*队头元素出队*/
extern int OutQueue(pQueue pqueue, char *pitem);

#endif /* __PQUEUE_H__ */

////////////////////////////////////////////////////////
#include "pqueue.h"		

#define err_log(fmt, ...) printf("[%s:%d]"fmt"\n", __FUNCTION__, __LINE__, ##__VA_ARGS__)
#define err_assert(con) { \
	if (!(con)) { \
		printf("[%s:%d]ASSERT>>> %s failed\n", __FUNCTION__, __LINE__, #con); \
		abort(); \
	} \
}
		

/*构造一个空队列*/
pQueue InitQueue()
{
	return (pQueue)calloc(1, sizeof(Queue));
}

/*销毁一个队列*/
void DestroyQueue(pQueue pqueue)
{
	err_assert(pqueue != NULL);
	
	if(!IsEmpty(pqueue))
		ClearQueue(pqueue);

	free(pqueue);
}

/*清空一个队列*/
void ClearQueue(pQueue pqueue)
{
	err_assert(pqueue != NULL);
	
	while (!IsEmpty(pqueue)) {
		OutQueue(pqueue, NULL);
	}
}

/*判断队列是否为空*/
int IsEmpty(pQueue pqueue)
{
	err_assert(pqueue != NULL);
	
	return !pqueue->size;
}

/*返回队列大小*/
int GetSize(pQueue pqueue)
{
	err_assert(pqueue != NULL);
	
	return pqueue->size;
}

/*返回队头元素*/
int GetFront(pQueue pqueue, char *pitem)
{
	err_assert(pqueue != NULL);
	
	if (IsEmpty(pqueue)) {
		return -1;
	}

	if (pitem) {
		err_assert(pqueue->front != NULL);
		strcpy(pitem, pqueue->front->data);
	}
	
	return 0;
}

/*返回队尾元素*/	
int GetRear(pQueue pqueue, char *pitem)
{
	err_assert(pqueue != NULL);
	
	if (IsEmpty(pqueue)) {
		return -1;
	}

	if (pitem) {
		err_assert(pqueue->rear != NULL);
		strcpy(pitem,pqueue->rear->data);
	}
	return 0;
}

/*将新元素入队*/
int InQueue(pQueue pqueue, char *pitem)
{
	err_assert(pqueue != NULL);
	
	pNode pnode = (pNode)calloc(1, sizeof(Node));
	if(NULL == pnode)  {
		return -1;
	}

	strcpy(pnode->data, pitem);
	pnode->next = NULL;
	if(IsEmpty(pqueue)) {
		pqueue->front = pnode;
	}
	else {
		pqueue->rear->next = pnode;
	}

	pqueue->rear = pnode;
	pqueue->size++;

	return 0;
}

/*队头元素出队*/
int OutQueue(pQueue pqueue,char *pitem)
{
	err_assert(pqueue != NULL);
	
	pNode pnode = pqueue->front;

	if (IsEmpty(pqueue)) {
		err_log("empty queue");
		return -1;
	}
	
	if (pitem)
		strcpy(pitem, pnode->data);

	pqueue->front = pnode->next;
	free(pnode);
	pqueue->size--;

	if (pqueue->size == 0 ){
		pqueue->rear = NULL;
	}

	return 0;
}

////////////////////////////////////////////////////////
#include "pqueue.h"		

int main(void)
{
	pQueue queue = NULL;

	queue = InitQueue();

	InQueue(queue, "I&#39;m ");
	InQueue(queue, "a ");
	InQueue(queue, "boy. ");

	while (!IsEmpty(queue)) {
		char buf[MAX_DATA_SIZE];
		if (OutQueue(queue, buf) < 0) {
			break;
		}
		printf("%s", buf);
	}
	
	printf("\n");
	DestroyQueue(queue);

	return 0;
}

Copier après la connexion

Le le problème est trouvé, ce n'est pas une file d'attente. La raison est que j'ai mal alloué un char* dans une fonction, puis j'ai appelé le char* renvoyé par la fonction dans le thread. Après l'avoir utilisé, je l'ai libéré (à la fin de la fonction. ). En conséquence, l'erreur ci-dessus a été signalée. J'ai commenté ceci. Après avoir dit gratuit, c'est bien. Ce qui est déroutant, c'est que je ne sais pas pourquoi il ne peut pas être gratuit

free devrait être placé dans. la fonction où vous écrivez malloc

*** glibc détectée *** double libre ou Corruption (!prev) :

Fait généralement référence à l'exploitation d'un objet libéré, tel que :
1. a été relâché, mais l'objet pointé par le pointeur est à nouveau actionné.

2. Un certain objet alloué dynamiquement en multi-threading est utilisé par deux threads en même temps. Un thread libère l'objet, tandis que l'autre thread continue de faire fonctionner l'objet.

Ajoutez une synchronisation de thread et il ne devrait y avoir aucun problème

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!