Line data    Source code

       1             : /**
       2             : Copyright (c) 2022 Roman Katuntsev <sbkarr@stappler.org>
       3             : Copyright (c) 2023 Stappler LLC <admin@stappler.dev>
       4             : 
       5             : Permission is hereby granted, free of charge, to any person obtaining a copy
       6             : of this software and associated documentation files (the "Software"), to deal
       7             : in the Software without restriction, including without limitation the rights
       8             : to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
       9             : copies of the Software, and to permit persons to whom the Software is
      10             : furnished to do so, subject to the following conditions:
      11             : 
      12             : The above copyright notice and this permission notice shall be included in
      13             : all copies or substantial portions of the Software.
      14             : 
      15             : THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
      16             : IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
      17             : FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
      18             : AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
      19             : LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
      20             : OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
      21             : THE SOFTWARE.
      22             : **/
      23             : 
      24             : #ifndef STAPPLER_THREADS_SPTHREAD_H_
      25             : #define STAPPLER_THREADS_SPTHREAD_H_
      26             : 
      27             : #include "SPRef.h"
      28             : 
      29             : namespace STAPPLER_VERSIONIZED stappler::thread {
      30             : 
      31             : struct ThreadInfo {
      32             :         static constexpr uint32_t mainThreadId = maxOf<uint32_t>() - 1;
      33             : 
      34             :         static ThreadInfo *getThreadLocal();
      35             :         static void setMainThread();
      36             :         static void setThreadInfo(uint32_t, uint32_t, StringView, bool);
      37             :         static void setThreadInfo(StringView);
      38             : 
      39             :         uint32_t threadId = 0;
      40             :         uint32_t workerId = 0;
      41             :         StringView name;
      42             :         bool managed = false;
      43             :         bool detouched = false;
      44             : };
      45             : 
      46             : /* Interface for thread workers or handlers */
      47             : template <typename Interface>
      48             : class ThreadInterface : public RefBase<Interface> {
      49             : public:
      50         515 :         virtual ~ThreadInterface() { }
      51             : 
      52             :         static const void *getOwner();
      53             :         static void workerThread(ThreadInterface *tm, const void *owner);
      54             : 
      55           0 :         virtual void threadInit() { }
      56           0 :         virtual void threadDispose() { }
      57           0 :         virtual bool worker() { return false; }
      58             : };
      59             : 
      60             : }
      61             : 
      62             : #endif /* STAPPLER_THREADS_SPTHREAD_H_ */