| /* |
| * Copyright (C) 2007 The Android Open Source Project |
| * |
| * Licensed under the Apache 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.apache.org/licenses/LICENSE-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 android.os; |
| |
| abstract class TestHandlerThread { |
| private boolean mDone = false; |
| private boolean mSuccess = false; |
| private RuntimeException mFailure = null; |
| private Looper mLooper; |
| |
| public abstract void go(); |
| |
| public TestHandlerThread() { |
| } |
| |
| public void doTest(long timeout) { |
| (new LooperThread()).start(); |
| |
| synchronized (this) { |
| long now = System.currentTimeMillis(); |
| long endTime = now + timeout; |
| while (!mDone && now < endTime) { |
| try { |
| wait(endTime-now); |
| } |
| catch (InterruptedException e) { |
| } |
| now = System.currentTimeMillis(); |
| } |
| } |
| |
| mLooper.quit(); |
| |
| if (!mDone) { |
| throw new RuntimeException("test timed out"); |
| } |
| if (!mSuccess) { |
| throw mFailure; |
| } |
| } |
| |
| public Looper getLooper() { |
| return mLooper; |
| } |
| |
| public void success() { |
| synchronized (this) { |
| mSuccess = true; |
| quit(); |
| } |
| } |
| |
| public void failure(RuntimeException failure) { |
| synchronized (this) { |
| mSuccess = false; |
| mFailure = failure; |
| quit(); |
| } |
| } |
| |
| class LooperThread extends Thread { |
| public void run() { |
| Looper.prepare(); |
| mLooper = Looper.myLooper(); |
| go(); |
| Looper.loop(); |
| |
| synchronized (TestHandlerThread.this) { |
| mDone = true; |
| if (!mSuccess && mFailure == null) { |
| mFailure = new RuntimeException("no failure exception set"); |
| } |
| TestHandlerThread.this.notifyAll(); |
| } |
| } |
| |
| } |
| |
| private void quit() { |
| synchronized (this) { |
| mDone = true; |
| notifyAll(); |
| } |
| } |
| } |