cannam@148: // Copyright (c) 2013-2014 Sandstorm Development Group, Inc. and contributors cannam@148: // Licensed under the MIT License: cannam@148: // cannam@148: // Permission is hereby granted, free of charge, to any person obtaining a copy cannam@148: // of this software and associated documentation files (the "Software"), to deal cannam@148: // in the Software without restriction, including without limitation the rights cannam@148: // to use, copy, modify, merge, publish, distribute, sublicense, and/or sell cannam@148: // copies of the Software, and to permit persons to whom the Software is cannam@148: // furnished to do so, subject to the following conditions: cannam@148: // cannam@148: // The above copyright notice and this permission notice shall be included in cannam@148: // all copies or substantial portions of the Software. cannam@148: // cannam@148: // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR cannam@148: // IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, cannam@148: // FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE cannam@148: // AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER cannam@148: // LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, cannam@148: // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN cannam@148: // THE SOFTWARE. cannam@148: cannam@148: #ifndef KJ_THREAD_H_ cannam@148: #define KJ_THREAD_H_ cannam@148: cannam@148: #if defined(__GNUC__) && !KJ_HEADER_WARNINGS cannam@148: #pragma GCC system_header cannam@148: #endif cannam@148: cannam@148: #include "common.h" cannam@148: #include "function.h" cannam@148: #include "exception.h" cannam@148: cannam@148: namespace kj { cannam@148: cannam@148: class Thread { cannam@148: // A thread! Pass a lambda to the constructor, and it runs in the thread. The destructor joins cannam@148: // the thread. If the function throws an exception, it is rethrown from the thread's destructor cannam@148: // (if not unwinding from another exception). cannam@148: cannam@148: public: cannam@148: explicit Thread(Function func); cannam@148: KJ_DISALLOW_COPY(Thread); cannam@148: cannam@148: ~Thread() noexcept(false); cannam@148: cannam@148: #if !_WIN32 cannam@148: void sendSignal(int signo); cannam@148: // Send a Unix signal to the given thread, using pthread_kill or an equivalent. cannam@148: #endif cannam@148: cannam@148: void detach(); cannam@148: // Don't join the thread in ~Thread(). cannam@148: cannam@148: private: cannam@148: struct ThreadState { cannam@148: Function func; cannam@148: kj::Maybe exception; cannam@148: cannam@148: unsigned int refcount; cannam@148: // Owned by the parent thread and the child thread. cannam@148: cannam@148: void unref(); cannam@148: }; cannam@148: ThreadState* state; cannam@148: cannam@148: #if _WIN32 cannam@148: void* threadHandle; cannam@148: #else cannam@148: unsigned long long threadId; // actually pthread_t cannam@148: #endif cannam@148: bool detached = false; cannam@148: cannam@148: #if _WIN32 cannam@148: static unsigned long __stdcall runThread(void* ptr); cannam@148: #else cannam@148: static void* runThread(void* ptr); cannam@148: #endif cannam@148: }; cannam@148: cannam@148: } // namespace kj cannam@148: cannam@148: #endif // KJ_THREAD_H_