Searched refs:jobQueue (Results 1 – 3 of 3) sorted by relevance
| /aoo42x/main/jurt/java/jurt/src/main/java/com/sun/star/lib/uno/environments/remote/ |
| H A D | JavaThreadPool.java | 57 JobQueue jobQueue = _javaThreadPoolFactory.getJobQueue(threadId); in attach() local
58 if(jobQueue == null) in attach()
59 jobQueue = new JobQueue(_javaThreadPoolFactory, threadId, false); in attach()
62 jobQueue.acquire(); in attach()
63 return jobQueue; in attach()
92 JobQueue jobQueue = _javaThreadPoolFactory.getJobQueue(job.getThreadId()); in putJob() local
97 if(jobQueue == null) in putJob()
98 jobQueue = new JobQueue(_javaThreadPoolFactory, job.getThreadId(), true); in putJob()
101 jobQueue.putJob(job, this); in putJob()
|
| H A D | JavaThreadPoolFactory.java | 37 public void addJobQueue(JobQueue jobQueue) { in addJobQueue() argument
39 jobQueues.put(jobQueue.getThreadId(), jobQueue); in addJobQueue() local
43 public void removeJobQueue(JobQueue jobQueue) { in removeJobQueue() argument
45 jobQueues.remove(jobQueue.getThreadId()); in removeJobQueue()
|
| /aoo42x/main/jurt/test/com/sun/star/lib/uno/environments/remote/ |
| H A D | JobQueue_Test.java | 147 private void testExecuteJobs(JobQueue jobQueue) throws InterruptedException in testExecuteJobs() argument
150 testSendRequests(workAt, "increment", jobQueue); in testExecuteJobs()
152 jobQueue.putJob(new Job(workAt, __iReceiver, in testExecuteJobs()
192 JobQueue jobQueue) { in testSendRequests() argument
199 jobQueue.putJob(new Job(workAt, __iReceiver, iMessage), in testSendRequests()
|
Completed in 23 milliseconds