concurrent

Blocking Queue example to execute commands

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
 
private BlockingQueue<Command> workQueue = new LinkedBlockingQueue<Command>();
 
public void addCommand(Command command) {
    workQueue.offer(command);
}
 
public Object call() throws Exception {
    try {

  Command command = workQueue.take();

  command.execute();
    } catch (InterruptedException e) {

  throw new WorkException(e);
    }
}

Related Article:

Reference: Java Concurrency Part 5 – Blocking Queues from our JCG partners at the Carfey Software blog

Byron Kiourtzoglou

Byron is a master software engineer working in the IT and Telecom domains. He is an applications developer in a wide variety of applications/services. He is currently acting as the team leader and technical architect for a proprietary service creation and integration platform for both the IT and Telecom industries in addition to a in-house big data real-time analytics solution. He is always fascinated by SOA, middleware services and mobile development. Byron is co-founder and Executive Editor at Java Code Geeks.
Subscribe
Notify of
guest

This site uses Akismet to reduce spam. Learn how your comment data is processed.

0 Comments
Inline Feedbacks
View all comments
Back to top button