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 65 milliseconds