JavaApns无法在ThreadPoolExecutor中使用？

为了保持一个ApnsService活着，我创建了一个ThreadPoolExecutor来保持线程发送推送。这里是工人的代码：JavaApns无法在ThreadPoolExecutor中使用？

公共静态类PushWorker实现Runnable {

private static final Logger log = Logger.getLogger(PushWorker.class); 

    private String token; 
    private String alert; 
    private int badge; 
    private String sound; 
    private ApnsService service; 

    public PushWorker(ApnsService srv, String t, String a, int b, String s){ 
     token = t; 
     alert = a; 
     badge = b; 
     sound = s; 
     service = srv; 
    } 
    @Override 
    public void run() { 


     PayloadBuilder payloadBuilder = APNS.newPayload(); 
     payloadBuilder.sound(sound); 
     payloadBuilder.badge(badge); 

     payloadBuilder.alertBody(alert); 


     String payload = payloadBuilder.build(); 
        service.push(token, payload); 

    } 
}

当我创建了一个工人，在一个线程池执行它：

的ThreadPoolExecutor池=新的ThreadPoolExecutor（corePoolSize ，maximumPoolSize，keepAliveTime，TimeUnit.SECONDS，queue）;

pool.execute（worker）;

程序终止于：PayloadBuilder payloadBuilder = APNS.newPayload（）;并没有任何错误或例外。但是，它可以工作，如果在以下方式：

PushWorker worker = new PushWorker（service，token，alert，badge，null）;

worker.run（）;

我不知道为什么线程终止在线程池...有没有人有同样的问题？

来源

2012-03-14 River

尝试使用

try { 
    Future result = pool.submit(worker) 
    result.get() 

} catch (ExecutionException e) { 
    // actual exception in e.getCause() 
}

代替

来源

2012-03-14 09:23:07

JavaApns无法在ThreadPoolExecutor中使用？

回答

相关问题