@EnableScheduling // 1.开启定时任务
@EnableAsync // 2.开启多线程
@Service
public class ChkMeetServiceImpl extends ServiceImpl<ChkMeetMapper, ChkMeet> implements ChkMeetService {
@Override
public void meetPublicity( Long meetId) throws SocketException {
ChkMeet chkMeet = chkMeetMapper.selectById(meetId);
ScheduledThreadPoolExecutor scheduled = new ScheduledThreadPoolExecutor(2);
scheduled.schedule(new Runnable() {
@Override
public void run() {
chkMeet.setWorkFlowState(3);
chkMeetMapper.updateById(chkMeet);
scheduled.shutdownNow();
}
}, 1, TimeUnit.MINUTES);//1表示执行任务的间隔时间,以分钟为单位
}
}