同步无限循环服务的初始化部分

Question

我正在尝试实现一段代码来同步启动Java中的循环服务。这个想法是， // STARTER 注释下的代码应该被视为 Service.go() 方法的一部分，所以如果服务启动失败，我想重新抛出同步异常。仅当我尝试启动线程，等待其执行流程到达某个点，接下来，如果没有问题，我的 go()< /code> 方法退出，线程继续运行，或者，如果出现问题，我可以从 go() 方法重新抛出线程的 run() 方法中捕获的异常。这是似乎工作正常的解决方案，但我很好奇是否可以将其缩短几倍:-)

public class Program {

private static boolean started;
private static Throwable throwable;

public static void main(String[] args) {
    final Object startedSetterLock = new Object();

    Thread thread = new Thread() {
        public void run() {
            System.out.printf("trying to start...\n");

            boolean ok;
            Throwable t = null;
            try {
                init();
                ok = true;
            } catch(Exception e) {
                ok = false;
                t = e;
            }

            synchronized(startedSetterLock) {
                started = ok;
                throwable = t;
                startedSetterLock.notifyAll();
            }

            if(!ok) {
                return;
            }

            while(true) {
                try {
                    System.out.printf("working...\n");
                    Thread.sleep(1000);
                } catch(InterruptedException e) {
                    System.out.printf("interrupted\n");
                }                   
            }
        }

        private void init() throws Exception { throw new Exception(); } // may throw
    };

            // STARTER
    synchronized(startedSetterLock) {
        thread.start();
        try {           
            startedSetterLock.wait();
        } catch(InterruptedException e) {
            System.out.printf("interrupted\n");
        }
    }       

    // here I'm 100% sure that service has either started or failed to start
    System.out.printf("service started: %b\n", started);
    if(!started) {
        throwable.printStackTrace();
    }
}
}

而且，还有一个原因在该线程中执行初始化代码，所以请不要建议在 go() 方法中显式运行初始化代码，然后将所有内容传递给线程。

谢谢！

Answer 1

重写 Thread.start() 方法怎么样？

public static void main(String[] args) {
    Thread t = new Thread() {
        public void run() {
            while (true) {
                try {
                    System.out.printf("working...\n");
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    System.out.printf("interrupted\n");
                }
            }
        }

        @Override
        public synchronized void start() {
            try {
                init();
            } catch (Exception e) {
                throw new RuntimeException(e);
            }
            super.start();
        }

        private void init() throws Exception {
            throw new Exception("test");
        }
    };

    t.start();
}