24#include <osl/diagnose.h>
25#include <uno/threadpool.h>
63 std::scoped_lock aGuard(
m_mutex );
70 std::scoped_lock aGuard(
m_mutex );
77 std::scoped_lock aGuard(
m_mutex );
85 if (pCurrent->getIdentifier()
86 != osl::Thread::getCurrentIdentifier())
96 ByteSequence aThreadId,
98 : m_aThreadPool(
std::move( aThreadPool ))
100 , m_aThreadId(
std::move( aThreadId ))
101 , m_bAsynchron( bAsynchron )
107 const ByteSequence &aThreadId,
121 std::unique_lock g(rThreadAdmin.
m_mutex);
146 osl_setThreadName(
"cppu_threadpool::ORequestThread");
void * enter(void const *nDisposeId, bool bReturnWhenNoJob=false)
ThreadPoolHolder m_aThreadPool
void setTask(JobQueue *, const ::rtl::ByteSequence &aThreadId, bool bAsynchron)
virtual void SAL_CALL onTerminated() override
::rtl::ByteSequence m_aThreadId
virtual ~ORequestThread() override
ORequestThread(ThreadPoolHolder aThreadPool, JobQueue *, ::rtl::ByteSequence aThreadId, bool bAsynchron)
virtual void SAL_CALL run() override
void remove_locked(rtl::Reference< ORequestThread > const &)
void remove(rtl::Reference< ORequestThread > const &)
std::deque< rtl::Reference< ORequestThread > > m_deque
bool add_locked(rtl::Reference< ORequestThread > const &)
#define SAL_WARN_IF(condition, area, stream)
css::uno::Reference< css::deployment::XPackageRegistry > create(css::uno::Reference< css::deployment::XPackageRegistry > const &xRootRegistry, OUString const &context, OUString const &cachePath, css::uno::Reference< css::uno::XComponentContext > const &xComponentContext)
void SAL_CALL uno_releaseIdFromCurrentThread() SAL_THROW_EXTERN_C()
sal_Bool SAL_CALL uno_bindIdToCurrentThread(sal_Sequence *pThreadId) SAL_THROW_EXTERN_C()