我用java编写了一个web服务器,需要一个任务类来将数据上传到另一个服务器,所以我这样做如下:
ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(5)
executor.scheduleAtFixedRate(new Task(), 0, 100, TimeUnit.SECOND);
有Task
器Runnable
。问题是,每次只安排一个线程运行这个new Task()
,其他线程只是空闲,如果有大量数据来,我存储数据的工作队列变得非常大,更糟糕的是,我无法在花药中获取实时数据服务器。我的英语太糟糕了,如果你明白我的意思,我正在徘徊,我想找到解决这个问题的方法,你能帮我吗?