Coverage Report

Coverage Report - org.kuali.student.common.ui.client.mvc.WorkQueue

Classes in this File

Line Coverage

Branch Coverage

Complexity

WorkQueue

0/22

0/12

1.75

0/3

1.75

0/5

1.75

 /**
  * Copyright 2010 The Kuali Foundation Licensed under the
  * Educational Community License, Version 2.0 (the "License"); you may
  * not use this file except in compliance with the License. You may
  * obtain a copy of the License at
  *
  * http://www.osedu.org/licenses/ECL-2.0
  *
  * Unless required by applicable law or agreed to in writing,
  * software distributed under the License is distributed on an "AS IS"
  * BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
  * or implied. See the License for the specific language governing
  * permissions and limitations under the License.
  */
 
 package org.kuali.student.common.ui.client.mvc;
 
 /**
  * @author Kuali Student Team
  */
 import java.util.LinkedList;
 
 public class WorkQueue {
     public static abstract class WorkItem {
         private boolean canceled = false;
 
         public abstract void exec(final Callback<Boolean> onCompleteCallback);
 
         public boolean isCanceled() {
             return this.canceled;
         }
 
         protected void setCanceled(final boolean canceled) {
             this.canceled = canceled;
         }
     }
 
     private boolean running = false;
     private final LinkedList<WorkItem> queue = new LinkedList<WorkItem>();
 
     private final Callback<Boolean> onCompleteCallback = new Callback<Boolean>() {
         @Override
         public void exec(final Boolean value) {
             processNext();
         }
     };
 
     public void clear() {
         for (final WorkItem item : queue) {
             item.setCanceled(true);
         }
         queue.clear();
     }
 
     public boolean isRunning() {
         return this.running;
     }
 
     private void processNext() {
         WorkItem item = null;
         while (!queue.isEmpty() && (item = queue.removeFirst()) != null) {
             if (item.isCanceled()) {
                 item = null;
             } else {
                 break;
             }
         }
         if (item == null) {
             running = false;
         } else {
             item.exec(onCompleteCallback);
         }
     }
 
     public void submit(final WorkItem item) {
         queue.add(item);
         if (!running) {
             running = true;
             processNext();
         }
     }
 }

1		/**
2		* Copyright 2010 The Kuali Foundation Licensed under the
3		* Educational Community License, Version 2.0 (the "License"); you may
4		* not use this file except in compliance with the License. You may
5		* obtain a copy of the License at
6		*
7		* http://www.osedu.org/licenses/ECL-2.0
8		*
9		* Unless required by applicable law or agreed to in writing,
10		* software distributed under the License is distributed on an "AS IS"
11		* BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
12		* or implied. See the License for the specific language governing
13		* permissions and limitations under the License.
14		*/
15
16		package org.kuali.student.common.ui.client.mvc;
17
18		/**
19		* @author Kuali Student Team
20		*/
21		import java.util.LinkedList;
22
23	0	public class WorkQueue {
24	0	public static abstract class WorkItem {
25	0	private boolean canceled = false;
26
27		public abstract void exec(final Callback<Boolean> onCompleteCallback);
28
29		public boolean isCanceled() {
30	0	return this.canceled;
31		}
32
33		protected void setCanceled(final boolean canceled) {
34	0	this.canceled = canceled;
35	0	}
36		}
37
38	0	private boolean running = false;
39	0	private final LinkedList<WorkItem> queue = new LinkedList<WorkItem>();
40
41	0	private final Callback<Boolean> onCompleteCallback = new Callback<Boolean>() {
42		@Override
43		public void exec(final Boolean value) {
44	0	processNext();
45	0	}
46		};
47
48		public void clear() {
49	0	for (final WorkItem item : queue) {
50	0	item.setCanceled(true);
51		}
52	0	queue.clear();
53	0	}
54
55		public boolean isRunning() {
56	0	return this.running;
57		}
58
59		private void processNext() {
60	0	WorkItem item = null;
61	0	while (!queue.isEmpty() && (item = queue.removeFirst()) != null) {
62	0	if (item.isCanceled()) {
63	0	item = null;
64		} else {
65		break;
66		}
67		}
68	0	if (item == null) {
69	0	running = false;
70		} else {
71	0	item.exec(onCompleteCallback);
72		}
73	0	}
74
75		public void submit(final WorkItem item) {
76	0	queue.add(item);
77	0	if (!running) {
78	0	running = true;
79	0	processNext();
80		}
81	0	}
82		}