In the system, I have an object - let's call it TaskProcessor
. It holds queue of tasks, which are executed by some pool of threads (ExecutorService
+ PriorityBlockingQueue
)
The result of each task is saved in the database under some unique identifier.
The user, who knows this unique identifier, may check the result of this task. The result could be in the database, but also the task could still wait in the queue for execution. In that case, UserThread
should wait until the task will be finished.
Additionally, the following assumptions are valid:
Someone else could enqueue the task to
TaskProcessor
and some randomUserThread
can access the result if he knows the unique identifier.UserThread
andTaskProcess
are in the same app.TaskProcessor
contains a pool of threads, andUserThread
is simply servlet Thread.UserThread
should be blocked when asking for the result, and the result is not completed yet.UserThread
should be unblocked immediately afterTaskProcessor
complete task (or tasks) grouped by a unique identifier
My first attempt (the naive one), was to check the result in the loop and sleep for some time:
// UserThread
while(!checkResultIsInDatabase(uniqueIdentifier))
sleep(someTime)
But I don't like it. First of all, I am wasting database connections. Moreover, if the task would be finished right after sleep, then the user will wait even if the result just appeared.
Next attempt was based on wait/notify:
//UserThread
while (!checkResultIsInDatabase())
taskProcessor.wait()
//TaskProcessor
... some complicated calculations
this.notifyAll()
But I don't like it either. If more UserThreads
will use TaskProcessor
, then they will be wakened up unnecessarily every time some task would be completed and moreover - they will make unnecessary database calls.
The last attempt was based on something which I called waitingRoom
:
//UserThread
Object mutex = new Object();
taskProcessor.addToWaitingRoom(uniqueIdentifier, mutex)
while (!checkResultIsInDatabase())
mutex.wait()
//TaskProcessor
... Some complicated calculations
if (uniqueIdentifierExistInWaitingRoom(taskUniqueIdentifier))
getMutexFromWaitingRoom(taskUniqueIdentifier).notify()
But it seems to be not secure. Between database check and wait()
, the task could be completed (notify()
wouldn't be effective because UserThread
didn't invoke wait()
yet), which may end up with deadlock.
It seems, that I should synchronize it somewhere. But I am afraid that it will be not effective. Is there a way to correct any of my attempts, to make them secure and effective? Or maybe there is some other, better way to do this?