Связь между двумя потоками C ++ UNIX

Затем основной поток должен создать сначала общую переменную. После этого вы можете создать оба потока и передать им указатель на общую переменную.

Итак, оба они знают, как взаимодействовать с общей переменной. Вам необходимо реализовать mutex или wxSemaphore в методах общей переменной.

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

Кроме того, создайте центральный объект перед созданием потоков и передайте ссылку на центральный объект на потоки.

Используйте мьютекс в центральном объекте для предотвращения одновременного доступа.

Создание одного центрального объекта в каждом потоке не является вариантом.

EDIT 1: добавление более подробной информации и примеров

Начнем с некоторых предположений. ОП указала, что

У меня есть 2 потока (1 wxTimer и 1 wxThread)

Честно говоря, я очень мало знаю о структуре wxWidgets, но всегда есть документация. Поэтому я вижу, что:

1. wxTimer предоставляет таймер, который будет выполнять метод wxTimer::Notify() когда истечет таймер. Документация ничего не говорит о выполнении потока (хотя есть примечание. Таймер может использоваться только из основного потока, который я не уверен, как понимать). Я могу догадаться, что мы должны ожидать, что метод Notify будет выполняться в потоке или потоках цикла цикла или цикла таймера.
2. wxThread предоставляет модель для выполнения Thread, которая запускает метод wxThread::Entry(). Запуск объекта wxThread фактически создаст поток, который запускает метод Entry.

Таким образом, ваша проблема в том, что вам нужен тот же объект для доступа как в wxTimer::Notify() и в wxThread::Entry().

Этот объект:

Это не одна переменная, а большая часть этого магазина в одном классе

например

struct SharedData {
  // NOTE: This is very simplistic.
  // since the information here will be modified/read by
  // multiple threads, it should be protected by one or more
  // mutexes
  // so probably a class with getter/setters will be better suited
  // so that access with mutexes can be enforced within the class.
  SharedData():var2(0) { }
  std::string var1;
  int var2;
};

из которых у вас есть пример:

std::shared_ptr<SharedData> myData=std::make_shared<SharedData>();

или, возможно, в форме указателя или, возможно, в качестве локальной переменной или атрибутом объекта

Вариант 1: общая ссылка

Вы действительно не используете wxTimer или wxThread, но классы, наследующие от них (по крайней мере, wxThread::Entry() является чисто виртуальным. В случае wxTimer вы можете изменить владельца на другой wxEvtHandler, который получит событие, но вам все равно необходимо обеспечить реализацию.

Таким образом, вы можете

class MyTimer: public wxTimer {
public:
   void Notify()  {
       // Your code goes here
       // but it can access data through the local reference
   }

   void setData(const std::shared_ptr<SharedData> &data) {
       mLocalReference=data
   }

private:
   std::shared_ptr<SharedData> mLocalReferece
};

Это необходимо будет установить:

MyTimer timer;
timer.setData(myData);
timer.StartOnece(10000); // wake me up in 10 secs.

Аналогично для потока

class MyThread: public wxThread {
public:
   void Entry()  {
       // Your code goes here
       // but it can access data through the local reference
   }

   void setData(const std::shared_ptr<SharedData> &data) {
       mLocalReference=data
   }

private:
   std::shared_ptr<SharedData> mLocalReferece
};

Это необходимо будет установить:

MyThread *thread=new MyThread();
thread->setData(myData);
thread->Run(); // threads starts running.

Option2 Использование синглтона.

Иногда вы не можете изменять MyThread или MyTimer... или слишком сложно перенаправить ссылку на myData на поток или экземпляры таймера... или вы слишком ленивы или слишком заняты, чтобы беспокоиться (остерегайтесь вашего технического долга ! !)

Мы можем настроить SharedData на:

struct SharedData {
  std::string var1;
  int var2;

  static SharedData *instance() {
      // NOTE that some mutexes are needed here
      // to prevent the case where first initialization
      // is executed simultaneously from different threads
      // allocating two objects, one of them leaked.
      if(!sInstance) {
          sInstance=new SharedData();
      }
      return sInstance
  }
private:
  SharedData():var2(0) { } // Note we've made the constructor private
  static SharedData *sInstance=0;
};

Этот объект (поскольку он позволяет создавать только один объект) может быть доступен из MyTimer::Notify() или MyThread::Entry() с помощью

SharedData::instance()->var1;

Интерлюдия: почему синглтоны злы

(или почему легкое решение может укусить вас в будущем).

• Что так плохо о одиночных играх?
• Почему синглтоны злы
• Синглтоны злы

Мои главные причины:

1. Там один и только один экземпляр... и вы можете подумать, что вам нужно только одно сейчас, но кто знает, что будет в будущем, вы сделали легкое решение проблемы кодирования, которая имеет далеко идущие последствия в архитектуре, и это может быть трудно вернуть.
2. Это не позволит делать инъекции зависимостей (потому что фактический класс используется при доступе к объекту).

Тем не менее, я не думаю, что можно полностью избежать. Он имеет свои возможности, он может решить вашу проблему, и это может сэкономить ваш день.

Вариант 3. Некоторая средняя земля.

Вы все равно можете организовать свои данные в центральном репозитории с помощью методов доступа к различным экземплярам (или различным реализациям) данных.

Этот центральный репозиторий может быть одноточечным (он действительно является центральным, распространенным и уникальным), но не является общими данными, а используется для извлечения общих данных, например, идентифицированных с помощью некоторого идентификатора (который может быть проще распределить между потоки с использованием опции 1)

Что-то вроде:

CentralRepository::instance()->getDataById(sharedId)->var1;

EDIT 2: комментарии после опубликованного OP (более) кода;)

Кажется, что ваш объект EvtFramePrincipal выполнит как обратный вызов таймера, так и будет содержать указатель ClientIdle для объекта Client (поток)... Я бы сделал:

1. Создайте класс Client с атрибутом Portage (указатель или интеллектуальный указатель).
2. Сделать EvtFramePrincipal содержать атрибут Portage (указатель или интеллектуальный указатель). Я предполагаю, что это будет иметь жизненный цикл всего приложения, поэтому объект Portage может совместно использовать этот жизненный цикл.
3. Добавьте блокировку Mutexes ко всем настройкам методов и попаданию в атрибут Portage, поскольку к ним можно получить доступ из нескольких потоков.
4. После создания экземпляра объекта Client установите ссылку на объект Portage, который содержит EvtFramePrincipal.
5. Клиент может получить доступ к Portage, потому что мы установили его ссылку, когда она была создана. Когда метод Entry запускается в своем потоке, он сможет получить к нему доступ.
6. EvtFramePrincipal может получить доступ к Portage (поскольку это один из его атрибутов), поэтому обработчик события для события таймера сможет получить к нему доступ.