DEV Community

Cover image for Use ScheduledExecutorService to implement delayed tasks — delayed video release
Keith
Keith

Posted on • Originally published at Medium

Use ScheduledExecutorService to implement delayed tasks — delayed video release

#java #executorservice #scheduled #springboot

Using ScheduledExecutorService can implement timed tasks (such as the function of timed release)

First define local variables in the class

ScheduledExecutorService service = Executors.newScheduledThreadPool(50);
Enter fullscreen mode Exit fullscreen mode

Executors.newScheduledThreadPool(50); Factory pattern is used here.

factory pattern

It is mainly to provide a transition interface for creating objects, so as to shield and isolate the specific process of creating objects and achieve the purpose of improving flexibility.

@PostMapping("/ops/scheduled/publish") public ResponseResult scheduledPublish(@RequestBody ScheduleVideoDto dto) { List<Integer> vids = dto.getVids(); if (vids.isEmpty()){ return ResponseResult.of().withErrorMessage("Failed to publish video, please select a video to publish"); } Date pushTime = dto.getPushTime(); if (pushTime==null){ return ResponseResult.of().withErrorMessage("Failed to publish the video, please re-select the publishing time"); } for (int i = 0; i< vids.size();i++){ int status = videoService.getStatusById(vids.get(i)); if (status==1) vids.remove(vids.get(i)); } if (vids.isEmpty()){ return ResponseResult.of().withErrorMessage("Failed to publish video, the selected videos are all published"); } long delay = pushTime.getTime() - System.currentTimeMillis(); vids.forEach(vid->{ videoService.updatePushTime(vid,pushTime); service.schedule(() -> videoService.publish(vid), delay, TimeUnit.MILLISECONDS); }); return ResponseResult.of(); }
Enter fullscreen mode Exit fullscreen mode

Pass in the release time PushTime in the dto passed in the interface

long delay = pushTime.getTime() - System.currentTimeMillis(); #The release time minus the current time is the delay time delay
Enter fullscreen mode Exit fullscreen mode

Calling ScheduledExecutorService

public ScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit);
Enter fullscreen mode Exit fullscreen mode

api method

It can realize the function of publishing video at a fixed time

Top comments (0)