/*
 * Copyright (c) 2014 Cable Television Laboratories, Inc. and others.  All rights reserved.
 *
 * This program and the accompanying materials are made available under the
 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
 * and is available at http://www.eclipse.org/legal/epl-v10.html
 */

package org.pcmm.concurrent.impl;

import java.util.concurrent.Callable;

import org.pcmm.concurrent.IWorker;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 *
 */
public class Worker implements IWorker {

	private int waitTimer;

	private Callable<?> task;
	private Logger logger = LoggerFactory.getLogger(IWorker.class);

	public Worker() {

	}

	public Worker(Callable<?> task) {
		this.task = task;
	}

	/*
	 * (non-Javadoc)
	 *
	 * @see java.lang.Runnable#run()
	 */
	@Override
	public void run() {
		try {
			if (waitTimer > 0)
				Thread.sleep(waitTimer);
			task.call();
		} catch (Throwable e) {
			logger.error(e.getMessage());
		}
	}

	/*
	 * (non-Javadoc)
	 *
	 * @see org.pcmm.threading.IWorker#task(java.util.concurrent.Callable)
	 */
	@Override
	public void task(Callable<?> c) {
		logger.debug("Task added " + c);
		this.task = c;
	}

	/*
	 * (non-Javadoc)
	 *
	 * @see org.pcmm.threading.IWorker#shouldWait(int)
	 */
	@Override
	public void shouldWait(int t) {
		logger.debug("Worker will start after :" + t + " ms");
		waitTimer = t;
	}

	/*
	 * (non-Javadoc)
	 *
	 * @see org.pcmm.threading.IWorker#done()
	 */
	@Override
	public void done() {
		logger.debug("worker finished tasks");

	}

}