Searched refs:JobQueue (Results 1 – 11 of 11) sorted by relevance
/aoo4110/main/cppu/source/threadpool/ |
H A D | jobqueue.cxx | 35 JobQueue::JobQueue() : in JobQueue() function in cppu_threadpool::JobQueue 44 JobQueue::~JobQueue() in ~JobQueue() 50 void JobQueue::add( void *pThreadSpecificData, RequestFun * doRequest ) in add() 62 void *JobQueue::enter( sal_Int64 nDisposeId , sal_Bool bReturnWhenNoJob ) in enter() 138 void JobQueue::dispose( sal_Int64 nDisposeId ) in dispose() 158 void JobQueue::suspend() in suspend() 164 void JobQueue::resume() in resume() 174 sal_Bool JobQueue::isEmpty() in isEmpty() 180 sal_Bool JobQueue::isCallstackEmpty() in isCallstackEmpty() 186 sal_Bool JobQueue::isBusy() in isBusy()
|
H A D | threadpool.cxx | 211 void ThreadPool::createThread( JobQueue *pQueue , in createThread() 293 JobQueue *pQueue = 0; in addJob() 301 m_mapQueue[ aThreadId ] = pair < JobQueue * , JobQueue * > ( 0 , 0 ); in addJob() 310 (*ii).second.second = new JobQueue(); in addJob() 319 (*ii).second.first = new JobQueue(); in addJob() 346 JobQueue *p = new JobQueue(); in prepare() 347 m_mapQueue[ aThreadId ] = pair< JobQueue * , JobQueue * > ( p , 0 ); in prepare() 351 (*ii).second.first = new JobQueue(); in prepare() 357 JobQueue *pQueue = 0; in enter()
|
H A D | thread.hxx | 35 class JobQueue; 46 ORequestThread( JobQueue * , 51 void setTask( JobQueue * , const ::rtl::ByteSequence & aThreadId , sal_Bool bAsynchron ); 63 JobQueue *m_pQueue;
|
H A D | jobqueue.hxx | 52 class JobQueue class 55 JobQueue(); 56 ~JobQueue();
|
H A D | threadpool.hxx | 61 ::std::pair < JobQueue * , JobQueue * >, 124 void createThread( JobQueue *pQueue, const ByteSequence &aThreadId, sal_Bool bAsynchron);
|
H A D | thread.cxx | 113 ORequestThread::ORequestThread( JobQueue *pQueue, in ORequestThread() 136 void ORequestThread::setTask( JobQueue *pQueue, in setTask()
|
/aoo4110/main/jurt/com/sun/star/lib/uno/environments/remote/ |
H A D | JavaThreadPoolFactory.java | 37 public void addJobQueue(JobQueue jobQueue) { in addJobQueue() 43 public void removeJobQueue(JobQueue jobQueue) { in removeJobQueue() 49 public JobQueue getJobQueue(ThreadId threadId) { in getJobQueue() 51 return (JobQueue) jobQueues.get(threadId); in getJobQueue() 55 public JobQueue getAsyncJobQueue(ThreadId threadId) { in getAsyncJobQueue() 56 JobQueue q = getJobQueue(threadId); in getAsyncJobQueue() 61 JobQueue[] qs; in dispose() 64 qs = (JobQueue[]) c.toArray(new JobQueue[c.size()]); in dispose() 73 if (t instanceof JobQueue.JobDispatcher) { in getThreadId() 74 return ((JobQueue.JobDispatcher) t).getThreadId(); in getThreadId()
|
H A D | JavaThreadPool.java | 57 JobQueue jobQueue = _javaThreadPoolFactory.getJobQueue(threadId); in attach() 59 jobQueue = new JobQueue(_javaThreadPoolFactory, threadId, false); in attach() 72 ((JobQueue)handle).release(); in detach() 87 return ((JobQueue)handle).enter(this); in enter() 92 JobQueue jobQueue = _javaThreadPoolFactory.getJobQueue(job.getThreadId()); in putJob() 98 jobQueue = new JobQueue(_javaThreadPoolFactory, job.getThreadId(), true); in putJob() 108 JobQueue async_jobQueue = _javaThreadPoolFactory.getAsyncJobQueue(job.getThreadId()); in putJob() 112 async_jobQueue = new JobQueue(_javaThreadPoolFactory, job.getThreadId()); in putJob()
|
H A D | JobQueue.java | 44 public class JobQueue { class 63 protected JobQueue _async_jobQueue; // chaining job qeueus for asyncs 64 protected JobQueue _sync_jobQueue; // chaining job qeueus for syncs 124 JobQueue(JavaThreadPoolFactory javaThreadPoolFactory, ThreadId threadId) { in JobQueue() method in JobQueue 130 _sync_jobQueue = new JobQueue(javaThreadPoolFactory, threadId, true); in JobQueue() 151 JobQueue(JavaThreadPoolFactory javaThreadPoolFactory, ThreadId threadId, boolean createThread){ in JobQueue() method in JobQueue
|
H A D | makefile.mk | 39 JobQueue.java \
|
/aoo4110/main/jurt/test/com/sun/star/lib/uno/environments/remote/ |
H A D | JobQueue_Test.java | 116 new JobQueue( in testDynamicThreadExecutesJob() 122 JobQueue async_jobQueue = new JobQueue(__javaThreadPoolFactory, in testStaticThreadExecutesAsyncs() 139 JobQueue async_jobQueue = new JobQueue(__javaThreadPoolFactory, in testDynamicThreadExecutesAsyncs() 147 private void testExecuteJobs(JobQueue jobQueue) throws InterruptedException in testExecuteJobs() 167 private void testAsyncJobQueue(TestWorkAt workAt, JobQueue async_jobQueue, in testAsyncJobQueue() 192 JobQueue jobQueue) { in testSendRequests() 207 public JobQueue _jobQueue = null; 212 _jobQueue = new JobQueue(__javaThreadPoolFactory, _threadId, false); in TestThread()
|
Completed in 75 milliseconds