Main.java revision aec9c8f142ad839883ae3de7383456a08823a282 
1// Copyright 2006 The Android Open Source Project
2
3/**
4 * Test synchronization primitives.
5 *
6 * TODO: this should be re-written to be a little more rigorous and/or
7 * useful.  Also, the ThreadDeathHandler stuff should be exposed or
8 * split out.
9 */
10public class Main {
11    public static void main(String[] args) {
12        System.out.println("Sleep Test");
13        sleepTest();
14
15        System.out.println("\nCount Test");
16        countTest();
17
18        System.out.println("\nInterrupt Test");
19        interruptTest();
20    }
21
22    static void sleepTest() {
23        System.out.println("GOING");
24        try {
25            Thread.sleep(1000);
26        } catch (InterruptedException ie) {
27            System.out.println("INTERRUPT!");
28            ie.printStackTrace();
29        }
30        System.out.println("GONE");
31    }
32
33    static void countTest() {
34        CpuThread one, two;
35
36        one = new CpuThread(1);
37        two = new CpuThread(2);
38
39        one.start();
40
41        try {
42            Thread.sleep(100);
43        } catch (InterruptedException ie) {
44            System.out.println("INTERRUPT!");
45            ie.printStackTrace();
46        }
47
48        two.start();
49
50        //System.out.println("main: off and running");
51
52        try {
53            one.join();
54            two.join();
55        } catch (InterruptedException ie) {
56            System.out.println("INTERRUPT!");
57            ie.printStackTrace();
58        }
59        System.out.println("main: all done");
60    }
61
62    static void interruptTest() {
63        SleepyThread sleepy, pesky;
64
65        sleepy = new SleepyThread(null);
66        pesky = new SleepyThread(sleepy);
67
68        sleepy.setPriority(4);
69        sleepy.start();
70        pesky.start();
71        pesky.setPriority(3);
72    }
73}
74
75class CpuThread extends Thread {
76    static Object mSyncable = new Object();
77    static int mCount = 0;
78    int mNumber;
79
80    CpuThread(int num) {
81        super("CpuThread " + num);
82        mNumber = num;
83    }
84
85    public void run() {
86        //System.out.print("thread running -- ");
87        //System.out.println(Thread.currentThread().getName());
88
89        synchronized (mSyncable) {
90            for (int i = 0; i < 10; i++) {
91                output(mNumber);
92            }
93
94            System.out.print("Final result: ");
95            System.out.println(mCount);
96        }
97    }
98
99    void output(int num) {
100        int count = mCount;
101
102        System.out.print("going: ");
103        System.out.println(num);
104
105        /* burn CPU; adjust end value so we exceed scheduler quantum */
106        for (int j = 0; j < 5000; j++) {
107            ;
108        }
109
110        count++;
111        mCount = count;
112    }
113}
114
115class SleepyThread extends Thread {
116    private SleepyThread mOther;
117    private Integer[] mWaitOnMe;      // any type of object will do
118
119    private static int count = 0;
120
121    SleepyThread(SleepyThread other) {
122        mOther = other;
123        mWaitOnMe = new Integer[] { 1, 2 };
124
125        setName("thread#" + count);
126        count++;
127    }
128
129    public void run() {
130        System.out.println("SleepyThread.run starting");
131
132        if (false) {
133            ThreadDeathHandler threadHandler =
134                new ThreadDeathHandler("SYNC THREAD");
135            Thread.currentThread().setUncaughtExceptionHandler(threadHandler);
136            throw new NullPointerException("die");
137        }
138
139        if (mOther == null) {
140            boolean intr = false;
141
142            try {
143                synchronized (mWaitOnMe) {
144                    mWaitOnMe.wait(9000);
145                }
146            } catch (InterruptedException ie) {
147                // Expecting this; interrupted should be false.
148                System.out.println(Thread.currentThread().getName() +
149                        " interrupted, flag=" + Thread.interrupted());
150                intr = true;
151            } catch (Exception ex) {
152                ex.printStackTrace();
153            }
154
155            if (!intr)
156                System.out.println("NOT INTERRUPTED");
157        } else {
158            try {
159                Thread.sleep(2000);
160            } catch (InterruptedException ie) {
161                System.out.println("PESKY INTERRUPTED?");
162            }
163
164            System.out.println("interrupting other (isAlive="
165                + mOther.isAlive() + ")");
166            mOther.interrupt();
167        }
168    }
169}
170