使用semaphore实现主程等待子线程执行结果

àì夳堔傛蜴生んèń 2022-11-02 13:30 141阅读 0赞

private static void updateSplash(Semaphore semaphore, EclipseStarter.StartupEventListener listener) {
            ServiceTracker<StartupMonitor, StartupMonitor> monitorTracker = new ServiceTracker(context, StartupMonitor.class.getName(), (ServiceTrackerCustomizer)null);
            monitorTracker.open();
    
            try {
                do {
                    StartupMonitor monitor = (StartupMonitor)monitorTracker.getService();
                    if (monitor != null) {
                        try {
                            monitor.update();
                        } catch (Throwable var7) {
                        }
                    }
                } while(!semaphore.acquire(50L));
            } finally {
                if (listener != null) {
                    context.removeFrameworkListener(listener);
                    context.removeBundleListener(listener);
                }
    
                monitorTracker.close();
            }
    
        }

在调用该方法前semaphore初始化参数为0.Listener中含有该信号量的引用，监听在其他线程执行逻辑的某个节点会release信号量。monitor为对子线程处理结果的实时监听器。

这样就可以实现主程在子线程处理过程中，每隔50毫秒对子线程的处理状态进行近实时返回，同时又可以在子线程结果完成后，继续执行主线程后续的逻辑。

使用信号量的好处是在等待子线程的返回时，可以设置定时释放锁，来进行一些实时监控或者其他的可以在轮询执行的逻辑。当然，其他的并发锁也有类似的功能