Печать страницы - Не получается синхронизировать потоки

Всем привет, очень бональная задача, но, тем не менее, не могу никак реализовать. Помогите пожалуйста.

Задача: Сервер прослущивает порт в основном потоке. В момент нового подключения создается поток, в который передается дискриптор сокета клиента.
Клиентов может подключаться неограниченное количество, т.о. потоков создаваться может множество. Во вновь созданном потоке
определяется объект класса, являющегося наследником класса сокет. В этом объекте у меня и происходит совственно считывание и
обработка полученных данных с сокета клиента. Переменная хранящая данные является глобальной, вследствии чего потоки не могут
её поделить между собой. Организовать синхронную работу так, чтобы работало с многими потоками не как не получается.

Есть ещё и вторая проблема: после очередной обработки сокета клиента и завершения потока размер занимаемой процессом памяти выростает
примерно на 100кб. Хотя везде вроде где надо делаю deleteLater(). Где происходит утечка? Отладчик так и не помог понять.

Код:

void CServer::incomingConnection(int socketDescriptor)
{
    th = new CClientThread(socketDescriptor);
    connect(th, SIGNAL(finished()), th, SLOT(deleteLater()));
    connect(th, SIGNAL(sendMsg(QString)), this, SIGNAL(sendMsg(QString)));
    th->moveToThread(th);
    th->start();
}

Код вновь создаваемого при подключении клиента потока:

Код:

// ----------------------------------------------------------------------
CClientThread::CClientThread(int obtained_descriptor, QObject *parent)
    : QThread(parent)
{
    socketDescriptor = obtained_descriptor;
}
// ----------------------------------------------------------------------
void CClientThread::run()
{
    NewConnect = new CConnection(socketDescriptor);

    emit sendMsg("connect from " + NewConnect->peerAddress().toString());
    connect(NewConnect, SIGNAL(sendMsg(QString)), this, SIGNAL(sendMsg(QString)));

    connect(NewConnect, SIGNAL(disconnected()), this, SLOT(quit()));

    connect(NewConnect, SIGNAL(readyRead()), NewConnect, SLOT(slotReadClient()));
    connect(NewConnect, SIGNAL(readChannelFinished()), NewConnect, SLOT(slotAfterRead()));
    connect(NewConnect, SIGNAL(disconnected()), NewConnect, SLOT(deleteLater()));

    exec();
}

Частичный код обработки подключения:

Код:

#include "connection.h"
// ----------------------------------------------------------------------
CConnection::CConnection(int obtained_descriptor, QObject *parent)
    : QTcpSocket(parent)
{
    this->setSocketDescriptor( obtained_descriptor );
}
// ----------------------------------------------------------------------
void CConnection::slotReadClient()
{
    QByteArray block;
    block = this->readAll();
    client_data += block;
}
// ----------------------------------------------------------------------
void CConnection::slotAfterRead()
{
    QString data = client_data;
    client_data = "";
    //writeDataToDB(data);
}

Гуру помогите! Очень хочется разобраться!

Russian Qt Forum

Qt => Работа с сетью => Тема начата: i-cpp от Апрель 06, 2010, 22:05