Home
last modified time | relevance | path

Searched refs:JobQueue (Results 1 – 11 of 11) sorted by relevance

/trunk/main/cppu/source/threadpool/
H A Djobqueue.cxx35 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 Dthreadpool.cxx211 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 Dthread.hxx35 class JobQueue;
46 ORequestThread( JobQueue * ,
51 void setTask( JobQueue * , const ::rtl::ByteSequence & aThreadId , sal_Bool bAsynchron );
63 JobQueue *m_pQueue;
H A Djobqueue.hxx52 class JobQueue class
55 JobQueue();
56 ~JobQueue();
H A Dthreadpool.hxx61 ::std::pair < JobQueue * , JobQueue * >,
124 void createThread( JobQueue *pQueue, const ByteSequence &aThreadId, sal_Bool bAsynchron);
H A Dthread.cxx113 ORequestThread::ORequestThread( JobQueue *pQueue, in ORequestThread()
136 void ORequestThread::setTask( JobQueue *pQueue, in setTask()
/trunk/main/jurt/java/jurt/src/main/java/com/sun/star/lib/uno/environments/remote/
H A DJavaThreadPoolFactory.java37 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 DJavaThreadPool.java57 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 DJobQueue.java44 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
/trunk/main/jurt/test/com/sun/star/lib/uno/environments/remote/
H A DJobQueue_Test.java109 new JobQueue( in testDynamicThreadExecutesJob()
116 JobQueue async_jobQueue = new JobQueue(__javaThreadPoolFactory, in testStaticThreadExecutesAsyncs()
134 JobQueue async_jobQueue = new JobQueue(__javaThreadPoolFactory, in testDynamicThreadExecutesAsyncs()
142 private void testExecuteJobs(JobQueue jobQueue) throws InterruptedException in testExecuteJobs()
162 private void testAsyncJobQueue(TestWorkAt workAt, JobQueue async_jobQueue, in testAsyncJobQueue()
187 JobQueue jobQueue) { in testSendRequests()
202 public JobQueue _jobQueue = null;
207 _jobQueue = new JobQueue(__javaThreadPoolFactory, _threadId, false); in TestThread()
/trunk/main/jurt/
H A DZip_jurt-src.mk63 com/sun/star/lib/uno/environments/remote/JobQueue.java \

Completed in 44 milliseconds