任务控制队列工具类

最近要写一个工具类，用静态方法控制执行的任务的最大数量。让其他的进入等待队列。主要用到了多线程的一些知识。

以下是代码

// 用于同步的锁
private static Object lock = new Object();
// 等待任务队列
private static List waitingList = new LinkedList();
// 正在运行的任务的数量
private static int workingCount = 0;
// 正在等待的任务的数量
private static volatile int waitingCount = 0;
// 最大允许同时运行的任务数量
private static int MAX_WORKING_COUNT = 100;
// 最大允许同时等待的任务数量
private static int MAX_WAITING_COUNT = 200;
// 下一个运行的任务
private static Object allowedTask = null;

// 等待运行，程序检查是否可以运行
// 如果可以，就会返回
// 如果不行，进入等待状态，直到唤醒并获得许可
public static void waitToRun(Object task)
{
	waitingCount ++; // 任务进入等待状态
	synchronized (lock)
	{
		// 如果达到允许运行任务数量的上限，则进入等待
		if (workingCount == MAX_WORKING_MEMORY_COUNT)
		{
			System.out.println("Waiting Memory: " + waitingMemoryCount);
			waitingList.add(task);
			// 被唤醒后需要检查是不是自己获得了运行许可，
			// 如果不是继续等待
			while (task!= allowedTask)
			{
				try
				{
					lock.wait();
				}
				catch (InterruptedException e) {}
			}
		}
		workingCount ++; // 任务进入运行状态
	}
}

// 任务运行完成后调用
public static void leaveAfterRun()
{
    synchronized(lock)
    {
    	workingMemoryCount --;
    	if (!waitingList.isEmpty())
    	{
    		allowedTask = waitingList.remove(0); // 更新下一个待运行的任务
    		lock.notifyAll(); //通知所有调用waitToRun等待的线程
    	}
    }
}

// 提交任务之前调用，确定是否可以提交
public static boolean canStillSubmitTask(int toSubmitCnt)
{
	return (waitingCount + toSubmitCnt) <= MAX_WAITING_COUNT;
}

上述的代码其实就是运用的wait/notify方式的线程同步