1a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert/* 2a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert * Copyright (C) 2010 The Android Open Source Project 3a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert * 4a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert * Licensed under the Apache License, Version 2.0 (the "License"); 5a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert * you may not use this file except in compliance with the License. 6a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert * You may obtain a copy of the License at 7a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert * 8a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert * http://www.apache.org/licenses/LICENSE-2.0 9a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert * 10a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert * Unless required by applicable law or agreed to in writing, software 11a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert * distributed under the License is distributed on an "AS IS" BASIS, 12a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 13a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert * See the License for the specific language governing permissions and 14a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert * limitations under the License. 15a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert */ 16a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert 17a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringertpackage com.android.quicksearchbox.util; 18a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert 19a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert 20a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringertimport java.util.HashMap; 21a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert 22a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert/** 23a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert * Uses a separate executor for each task name. 24a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert */ 25a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringertpublic class PerNameExecutor implements NamedTaskExecutor { 26a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert 27a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert private final Factory<NamedTaskExecutor> mExecutorFactory; 28a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert private HashMap<String, NamedTaskExecutor> mExecutors; 29a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert 30a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert /** 31a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert * @param executorFactory Used to run the commands. 32a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert */ 33a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert public PerNameExecutor(Factory<NamedTaskExecutor> executorFactory) { 34a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert mExecutorFactory = executorFactory; 35a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert } 36a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert 37a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert public synchronized void cancelPendingTasks() { 384572856ac85bb53ea06e65d00beebdf336af9b27Mathew Inwood if (mExecutors == null) return; 39a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert for (NamedTaskExecutor executor : mExecutors.values()) { 40a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert executor.cancelPendingTasks(); 41a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert } 42a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert } 43a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert 44a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert public synchronized void close() { 454572856ac85bb53ea06e65d00beebdf336af9b27Mathew Inwood if (mExecutors == null) return; 46a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert for (NamedTaskExecutor executor : mExecutors.values()) { 47a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert executor.close(); 48a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert } 49a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert } 50a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert 51a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert public synchronized void execute(NamedTask task) { 52a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert if (mExecutors == null) { 53a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert mExecutors = new HashMap<String, NamedTaskExecutor>(); 54a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert } 55a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert String name = task.getName(); 56a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert NamedTaskExecutor executor = mExecutors.get(name); 57a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert if (executor == null) { 58a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert executor = mExecutorFactory.create(); 59a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert mExecutors.put(name, executor); 60a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert } 61a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert executor.execute(task); 62a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert } 63a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert 64a48af083ff81555261f334a1e050eae3b02a746cBjorn Bringert} 65