Blocking Queue example to execute commands (original) (raw)

import java.util.concurrent.BlockingQueue; import java.util.concurrent.LinkedBlockingQueue;

private BlockingQueue workQueue = new LinkedBlockingQueue();

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:

• Java Concurrency Tutorial – Blocking Queues

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

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.