aboutsummaryrefslogtreecommitdiff
path: root/src/com/android/tv/dvr/provider/AsyncDvrDbTask.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/com/android/tv/dvr/provider/AsyncDvrDbTask.java')
-rw-r--r--src/com/android/tv/dvr/provider/AsyncDvrDbTask.java60
1 files changed, 18 insertions, 42 deletions
diff --git a/src/com/android/tv/dvr/provider/AsyncDvrDbTask.java b/src/com/android/tv/dvr/provider/AsyncDvrDbTask.java
index c5383d02..7d2af9c3 100644
--- a/src/com/android/tv/dvr/provider/AsyncDvrDbTask.java
+++ b/src/com/android/tv/dvr/provider/AsyncDvrDbTask.java
@@ -20,27 +20,23 @@ import android.content.Context;
import android.database.Cursor;
import android.os.AsyncTask;
import android.support.annotation.Nullable;
-
+import com.android.tv.common.concurrent.NamedThreadFactory;
import com.android.tv.dvr.data.ScheduledRecording;
import com.android.tv.dvr.data.SeriesRecording;
import com.android.tv.dvr.provider.DvrContract.Schedules;
import com.android.tv.dvr.provider.DvrContract.SeriesRecordings;
-import com.android.tv.util.NamedThreadFactory;
-
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
-/**
- * {@link AsyncTask} that defaults to executing on its own single threaded Executor Service.
- */
+/** {@link AsyncTask} that defaults to executing on its own single threaded Executor Service. */
public abstract class AsyncDvrDbTask<Params, Progress, Result>
extends AsyncTask<Params, Progress, Result> {
- private static final NamedThreadFactory THREAD_FACTORY = new NamedThreadFactory(
- AsyncDvrDbTask.class.getSimpleName());
- private static final ExecutorService DB_EXECUTOR = Executors
- .newSingleThreadExecutor(THREAD_FACTORY);
+ private static final NamedThreadFactory THREAD_FACTORY =
+ new NamedThreadFactory(AsyncDvrDbTask.class.getSimpleName());
+ private static final ExecutorService DB_EXECUTOR =
+ Executors.newSingleThreadExecutor(THREAD_FACTORY);
private static DvrDatabaseHelper sDbHelper;
@@ -57,9 +53,7 @@ public abstract class AsyncDvrDbTask<Params, Progress, Result>
mContext = context;
}
- /**
- * Execute the task on the {@link #DB_EXECUTOR} thread.
- */
+ /** Execute the task on the {@link #DB_EXECUTOR} thread. */
@SafeVarargs
public final void executeOnDbThread(Params... params) {
executeOnExecutor(DB_EXECUTOR, params);
@@ -71,15 +65,11 @@ public abstract class AsyncDvrDbTask<Params, Progress, Result>
return doInDvrBackground(params);
}
- /**
- * Executes in the background after {@link #initializeDbHelper(Context)}
- */
+ /** Executes in the background after {@link #initializeDbHelper(Context)} */
@Nullable
protected abstract Result doInDvrBackground(Params... params);
- /**
- * Inserts schedules.
- */
+ /** Inserts schedules. */
public static class AsyncAddScheduleTask
extends AsyncDvrDbTask<ScheduledRecording, Void, Void> {
public AsyncAddScheduleTask(Context context) {
@@ -93,9 +83,7 @@ public abstract class AsyncDvrDbTask<Params, Progress, Result>
}
}
- /**
- * Update schedules.
- */
+ /** Update schedules. */
public static class AsyncUpdateScheduleTask
extends AsyncDvrDbTask<ScheduledRecording, Void, Void> {
public AsyncUpdateScheduleTask(Context context) {
@@ -109,9 +97,7 @@ public abstract class AsyncDvrDbTask<Params, Progress, Result>
}
}
- /**
- * Delete schedules.
- */
+ /** Delete schedules. */
public static class AsyncDeleteScheduleTask
extends AsyncDvrDbTask<ScheduledRecording, Void, Void> {
public AsyncDeleteScheduleTask(Context context) {
@@ -125,9 +111,7 @@ public abstract class AsyncDvrDbTask<Params, Progress, Result>
}
}
- /**
- * Returns all {@link ScheduledRecording}s.
- */
+ /** Returns all {@link ScheduledRecording}s. */
public abstract static class AsyncDvrQueryScheduleTask
extends AsyncDvrDbTask<Void, Void, List<ScheduledRecording>> {
public AsyncDvrQueryScheduleTask(Context context) {
@@ -150,9 +134,7 @@ public abstract class AsyncDvrDbTask<Params, Progress, Result>
}
}
- /**
- * Inserts series recordings.
- */
+ /** Inserts series recordings. */
public static class AsyncAddSeriesRecordingTask
extends AsyncDvrDbTask<SeriesRecording, Void, Void> {
public AsyncAddSeriesRecordingTask(Context context) {
@@ -166,9 +148,7 @@ public abstract class AsyncDvrDbTask<Params, Progress, Result>
}
}
- /**
- * Update series recordings.
- */
+ /** Update series recordings. */
public static class AsyncUpdateSeriesRecordingTask
extends AsyncDvrDbTask<SeriesRecording, Void, Void> {
public AsyncUpdateSeriesRecordingTask(Context context) {
@@ -182,9 +162,7 @@ public abstract class AsyncDvrDbTask<Params, Progress, Result>
}
}
- /**
- * Delete series recordings.
- */
+ /** Delete series recordings. */
public static class AsyncDeleteSeriesRecordingTask
extends AsyncDvrDbTask<SeriesRecording, Void, Void> {
public AsyncDeleteSeriesRecordingTask(Context context) {
@@ -198,9 +176,7 @@ public abstract class AsyncDvrDbTask<Params, Progress, Result>
}
}
- /**
- * Returns all {@link SeriesRecording}s.
- */
+ /** Returns all {@link SeriesRecording}s. */
public abstract static class AsyncDvrQuerySeriesRecordingTask
extends AsyncDvrDbTask<Void, Void, List<SeriesRecording>> {
public AsyncDvrQuerySeriesRecordingTask(Context context) {
@@ -214,8 +190,8 @@ public abstract class AsyncDvrDbTask<Params, Progress, Result>
return null;
}
List<SeriesRecording> scheduledRecordings = new ArrayList<>();
- try (Cursor c = sDbHelper.query(SeriesRecordings.TABLE_NAME,
- SeriesRecording.PROJECTION)) {
+ try (Cursor c =
+ sDbHelper.query(SeriesRecordings.TABLE_NAME, SeriesRecording.PROJECTION)) {
while (c.moveToNext() && !isCancelled()) {
scheduledRecordings.add(SeriesRecording.fromCursor(c));
}