Thread.h

/*
Copyright (c) 2026 Alexandr Kuzmuk
 
This file is part of the AsyncFw project. Licensed under the MIT License.
See {Link: LICENSE file https://mit-license.org} in the project root for full license information.
*/
 
#pragma once
 
#include "FunctionConnector.h"
 
namespace AsyncFw {
class AbstractSocket;

class Thread : public AbstractThread {
  friend AbstractSocket;
  friend class ListenSocket;
  friend LogStream &operator<<(LogStream &, const Thread &);
 
public:
  static Thread *currentThread();

  Thread(const std::string & = "Thread");
  ~Thread() override;

  FunctionConnectorProtected<Thread>::Connector<> started;
  FunctionConnectorProtected<Thread>::Connector<> finished;
  FunctionConnectorProtected<Thread>::Connector<> destroing;
 
protected:
  void startedEvent() override;
  void finishedEvent() override;
 
  std::vector<AbstractSocket *> sockets_;
 
private:
  struct Compare {
    bool operator()(const AbstractSocket *, const AbstractSocket *) const;
  };
  void appendSocket(AbstractSocket *);
  void removeSocket(AbstractSocket *);
};
}  // namespace AsyncFw