Переменная в потоке

[SilverFish]

Сложный вопрос. Попробую расписать схему:
1.

Код

//IdTCPServer1 создает отдельный поток
void __fastcall TForm1Main::IdTCPServer1Execute(TIdContext *AContext)
{
 //прием данных и затем вызов функции:
 String Sdata = AContext->Connection->IOHandler->ReadLn();
 ParseJSONValue(Sdata);
}

2.

Код

//в функции идет разбор json пакета
void ParseJSONValue(String JsonData)
{
 //при первом вызове ParseJSONValue строка JsonData содержит внутри себя нужный параметр.
 //после обработки JsonData  я этот параметр сохраняю в переменную
 String JsonMemberNameID =тут нужное значение...;
 
 //при следующих вызовах ParseJSONValue JsonMemberNameID будет пустым т.к. нужный параметр только в первом пакете
 //String JsonMemberNameID =пусто;
 
 //после этого вызывается следующая функция, где JsonMemberNameID передается вторым параметром
 ParseJsonArraySens(CoderjimoeJsonArraySens, JsonMemberNameID);
}

3.

Код:

void ParseJsonArraySens(String CoderjimoeJsonArraySens, String sServerID)
{
 String ServerID = sServerID;//вот он наш параметр
 //используем его  
 //***

}

Все это прекрасно работает когда в IdTCPServer1Execute приходит первый пакет json. Первый пакет содержит нужный параметр.
При следующих приходах json данных значение String JsonMemberNameID уже пустое. Нужное значение приходит только в первом пакете.
Как мне в потоке созданном IdTCPServer1Execute запомнить JsonMemberNameID которое инициализируемый при первом вызове IdTCPServer1Execute? Это значение мне нужно для постоянной записи в базу данных при приходе пакетов данных.
Мне надо для потокобезопасности в каждом потоке созданном IdTCPServer1Execute иметь доступ к значению JsonMemberNameID внутри этого потока.

[OVE]

А параметр JsonMemberNameID для каждого потока свой будет или один на всех?

[SilverFish]

А параметр JsonMemberNameID для каждого потока свой будет или один на всех?

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

[OVE]

Тогда нужно создать структуру типа

Код:

struct TTT
{
  HANDLE hnd;
  String JsonMemberNameID;
}
......
vector tVect;

В качестве nhd указывать уникальный HANDLE потока.

[SilverFish]

Можно поподробнее расписать как это вмонтировать в мой код. Как все будет выглядеть. Где объявлять структуру? Как получить хендл потока?

[OVE]

Похоже, можно, сделать проще.
В переменной типа TIdContext, которая передается в OnExecute есть свойство Data. В нем и можно будет запоминать необходимую нам информацию (JsonMemberNameID).

Код:

void __fastcall TForm1Main::IdTCPServer1Execute(TIdContext *AContext)
{
 //прием данных и затем вызов функции:
 String Sdata = AContext->Connection->IOHandler->ReadLn();
 ParseJSONValue(AContext,Sdata);
}

Я думаю, должно работать.
//в функции идет разбор json пакета
void ParseJSONValue(TIdContext *AContext,String JsonData)
{
 //при первом вызове ParseJSONValue строка JsonData содержит внутри себя нужный параметр.
 //после обработки JsonData  я этот параметр сохраняю в переменную
 if(AContext->Data==NULL)
 { String JsonMemberNameID =тут нужное значение...;
   AContext->Data=(TObject*)new String(JsonMemberNameID);
 }
 //при следующих вызовах ParseJSONValue JsonMemberNameID будет пустым т.к. нужный параметр только в первом пакете
 //String JsonMemberNameID =пусто;
 
 //после этого вызывается следующая функция, где JsonMemberNameID передается вторым параметром
 ParseJsonArraySens(CoderjimoeJsonArraySens, *(Sting*)AContext->Data);
}

[SilverFish]

Может я не поняла, но вроде работать не будет.
AContext->Data не бывает NULL. Всегда приходят данные. Только в первом пакете данных есть чуть больше чем в следующих. Я из первого пакета данных беру нужное значение. Затем во всех других приходах данных приходит усеченные пакеты. Усеченный пакет приходит всегда во второй-третий-раз и до бесконечности. А вот в самом первом пакете есть нужные данные для JsonMemberNameID + усеченный пакет. Усеченные пакеты нужны и обрабатываются.
А JsonMemberNameID нужен индивидуально для каждого созданного потока...

[OVE]

Я сам с инди не работал, но насколько я понял из описания - Data это не данные, а указатель, в который пользователь может заносить какую-то свою информацию.

Data - A user-specified object with values used during execution of the task.

Мне кажется - должно работать.

[SilverFish]

Работает. Вижу нужные данные в базе данных.
Однако при закрытии приложения возникает AV обращения по адрес.
В закрытии формы:
IdTCPServer1->Active = false;

[SilverFish]

Вот тут вроде полезная информация:
http://borland.newsgroups.archived.at/public.delphi.internet.winsock/200804/08041613764.html
но нифига не понятно на паскале.

[SilverFish]

Код

  type
        TMyContext = class(TIdContext)
        public
            Description: String;
            procedure Reset;
            // anything else you want...
        end;
 
    procedure TForm1.FormCreate(Sender: TObject);
    begin
        IdTCPServer1.ContextClass := TMyContext;
        IdTCPServer1.Active := True;
    end;
 
    procedure TForm1.IdTCPServer1Connect(AContext: TIdContext);
    begin
        TMyContext(AContext).Reset;
    end;
 
    procedure TForm1.IdTCPServer1Disconnect(AContext: TIdContext);
    begin
        TMyContext(AContext).Reset;
    end;
 
    procedure TForm1.IdTCPServer1Execute(AContext: TIdContext);
    begin
        TMyContext(AContext).Description := ...;
    end;
 

Как это будет на С++?
Что такое procedure Reset? И как будет на С++ TMyContext(AContext).Reset?
Можно это приспособить под мою задачу?

[OVE]

Возможно, это происходит из-за того, что мы не чистим Data при закрытии.
Нужно в событии OnDisconnect очистить выделенную под JsonMemberNameID память

Код:

void __fastcall TForm1Main::IdTCPServer1OnDisconnect(TIdContext *AContext)
{
  if(AContext->Data) delete (String*)AContext->Data;
  AContext->Data=NULL;
}

[OVE]

1-ый вариант из сылки - это то, что мы и сделали. А во втором - подменяется класс TIdContext на пользовательский.

Что такое procedure Reset? И как будет на С++ TMyContext(AContext).Reset?

Reset - это какая-то пользовательская функция (которая в коде не описана).
((TMyContext*)AContext)->Reset()

[SilverFish]

Огромное спасибо вроде заработало после этого
 if(AContext->Data) delete (String*)AContext->Data;
  AContext->Data=NULL;
 

P.S.
А почему тут надо двойной указатель?
ParseJsonArraySens(CoderjimoeJsonArraySens, *(String*)AContext->Data);

[OVE]

А почему тут надо двойной указатель?
ParseJsonArraySens(CoderjimoeJsonArraySens, *(String*)AContext->Data);

В AContext->Data по факту у нас находится указатель на строку.
(String*)AContext->Data - это приведение типа к типу "указатель на строку"
А поскольку в функцию мы передаем строку, то нужно сделать разименовывание
*(String*)AContext->Data

[SilverFish]

Большое спасибо за подробные разъяснения и помощь!

P.S.
Оказывается Indy удобная штука.

[SilverFish]

Вот еще такое решение нашлось через класс:

Код:

   class TMyData : public TObject
    {
    public:
        String Value;
        __fastcall TMyData(const String &aValue) : TObject(), Value(aValue) {}
    };

    void ParseJSONValue(String JsonData, String ServerPascalIP, TIdContext *AContext)
    {
        //*****
        If (AContext->Data == NULL)
        {
            JsonMemberNameID = JsonMemberValue;
            AContext->Data = new TMyData(JsonMemberNameID);
        }
        //****
        ParseJsonArraySens(CoderjimoeJsonArraySens, static_cast(AContext->Data)->Value);
    }

    void __fastcall TForm1Main::IdTCPServer1Disconnect(TIdContext *AContext)
    {
        delete AContext->Data;
        AContext->Data = NULL;
    }

Вопрос такой:
можно ли в AContext->Data иметь, например, два значения и извлекать их оттуда?

[S0mbre]

можно ли в AContext->Data иметь, например, два значения и извлекать их оттуда?

Почему же нет? Хоть сколько переменных, ты же объявляешь пользовательский класс, наследуя от TObject. В этом классе объявляй хоть сколько, хоть какого типа переменные. Можешь даже типа Variant - и приводить их к любым другим типам.

[SilverFish]

Если сделать такое объявление:

Код

class TMyData : public TObject
    {
    public:
        String Value;
        int count;
        __fastcall TMyData(const String &aValue) : TObject(), Value(aValue), count(acount) {}
    }
 

То надо обращаться так:

Код

String NameID = "...";
int zes = 16;
AContext->Data = new TMyData(NameID, zes);
//Доступ так:
//static_cast(AContext->Data)->count;//int
//static_cast(AContext->Data)->Value;//String
//****
 
 void __fastcall TForm1Main::IdTCPServer1Disconnect(TIdContext *AContext)
    {
        delete AContext->Data;
        AContext->Data = NULL;
    }

Правильно?

[S0mbre]

Правильно?

Да. Только в конструкторе TMyData пропустила int acount.

[SilverFish]

Большое спасибо!

[SilverFish]

Еще вариант нашелся.   
Не требует освобождения AContext->Data

Код

    class TMyContext : public TIdServerContext
    {
    public:
        String Value;
    };
 
    __fastcall TForm1Main::TForm1Main(TComponent *Owner)
        : TForm(Owner)
    {
        IdTCPServer1->ContextClass = __classid(TMyContext);
    }
 
    void ParseJSONValue(String JsonData, String ServerPascalIP, TIdContext *AContext)
    {
        TMyContext *Ctx = static_castTMyContext*>(AContext);
 
        //****
 
        If (Ctx->Value == "")
        {
            JsonMemberNameID = JsonMemberValue;
            Ctx->Value = JsonMemberNameID;
        }
 
        //****
 
        ParseJsonArraySens(CoderjimoeJsonArraySens, Ctx->Value);
    }