Многопоточность для функции обратного вызова в C ++ - PullRequest
Новая
       32

Многопоточность для функции обратного вызова в C ++

1 голос
/ 04 января 2011

Я реализую приложение чата с использованием Jabber / XMPP и gloox framework, которое должно одновременно отправлять и получать сообщения в Ubuntu Linux.

Моя текущая реализация кода: 

int main()
{
        ...
 int temp = pthread_create(&iSend, NULL, SendMessage, &b);
 int temp1 = pthread_create(&iRecv, NULL, ConnServer, &b);
}

void* ConnServer(void *athis)
{
 UserClient *t = (UserClient*)athis;
 t->ConnecttosServer();
}

bool UserClient::ConnecttosServer()
{
 //JID jid( "map@jo-hely.hu/gloox" );

 j = new Client( iUserJid, iUser.getPassword() );
 j->registerMessageHandler( this);
 j->registerConnectionListener( this );
 j->registerMessageSessionHandler(this);
 bool result = j->connect(false);
 if(result == true)
 {
  iConnected = true;
  ConnectionError er = ConnNoError;
  ConnectionError er1 = ConnNoError;
  while(er == ConnNoError || er1 == ConnNoError)
  {
   er = j->recv(500000);
   sleep(2);
  }
  delete j;
 }
...
}

void* SendMessage(void * athis )// JID *aDest)
{
 UserClient *t = (UserClient*)athis;
 //JID *t = (JID)dest;

 string ip ;
 cout << "enter here";
 cin >> ip;
 if(t->iConnected == true)
 {
  if(t->iMessageSession == NULL )
  {
   string aBody = "hello";

   MessageSession *session = new MessageSession(t->j, t->iDestJid);
   session->registerMessageHandler(t);
   session->send(aBody.c_str());
  } 
 }
}

Проблема, с которой сталкиваются, состоит в том, что оба потока созданы, и pthread_join () вызывается для обоих.

Поток iSend запланирован первым, но приостановлен в cin. Как только вызывается функция recv (), которая выполняется в потоке iRecv, вызывается функция handleMessage () обратного вызова recv. Однако элемент управления никогда не возвращается к потоку iSend, который должен вызывать функцию SendMessage ().

Пожалуйста, помогите

Ответы [ 2 ]

0 голосов
/ 15 июля 2011

Вы не можете рассчитывать на поток iSend, запланированный первым.Это полностью зависит от операционной системы.

0 голосов
/ 04 января 2011

Я не могу видеть, как SendMessage отправляет более одного сообщения "hello".

Конечно, здесь возникают различные проблемы с памятью, например, j не удаляется вообще, если соединение не удалось, и какего сфера действия только для функций, и нет никакой необходимости создавать его с новым.

...