Java 类java.util.Timer 实例源码

/**
 * Starts the Scheduler which submits our data every 30 minutes.
 */
private void startSubmitting() {
    final Timer timer = new Timer(true); // We use a timer cause the Bukkit scheduler is affected by server lags
    timer.scheduleAtFixedRate(new TimerTask() {
        @Override
        public void run() {
            if (!plugin.isEnabled()) { // Plugin was disabled
                timer.cancel();
                return;
            }
            // Nevertheless we want our code to run in the Bukkit main thread, so we have to use the Bukkit scheduler
            // Don't be afraid! The connection to the bStats server is still async, only the stats collection is sync ;)
            Bukkit.getScheduler().runTask(plugin, new Runnable() {
                @Override
                public void run() {
                    submitData();
                }
            });
        }
    }, 1000*60*5, 1000*60*30);
    // Submit the data every 30 minutes, first time after 5 minutes to give other plugins enough time to start
    // WARNING: Changing the frequency has no effect but your plugin WILL be blocked/deleted!
    // WARNING: Just don't do it!
}

private void updateTime() {
    Timer commandExecutionTimer = new Timer();
    commandExecutionTimer.schedule(new TimerTask() {

        @Override
        public void run() {

                    doSetTrackInfo();
                    if (updateTime) {
                        updateTime();
                    }
                }


    }, 1000L);

}

public void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        Timer timer = new Timer();
        TimerTask updateTask = new TimerTask() {
            @Override
            public void run() {
                executeUpdate();
            }
        };

        TimerTask scrollTask = new TimerTask() {
            @Override
            public void run() {
                scrollTab();
            }
        };

        timer.schedule(updateTask, 1, 240000);
//        timer.schedule(scrollTask, 10000, 10000);
    }

private void startSubmitting() {
    // We use a timer cause want to be independent from the server tps
    final Timer timer = new Timer(true);
    timer.scheduleAtFixedRate(new TimerTask() {
        @Override
        public void run() {
            // Plugin was disabled, e.g. because of a reload (is this even possible in Sponge?)
            if (!Sponge.getPluginManager().isLoaded(plugin.getId())) {
                timer.cancel();
                return;
            }
            // The data collection (e.g. for custom graphs) is done sync
            // Don't be afraid! The connection to the bStats server is still async, only the stats collection is sync ;)
            Scheduler scheduler = Sponge.getScheduler();
            Task.Builder taskBuilder = scheduler.createTaskBuilder();
            taskBuilder.execute(() -> submitData()).submit(plugin);
        }
    }, 1000*60*5, 1000*60*30);
    // Submit the data every 30 minutes, first time after 5 minutes to give other plugins enough time to start
    // WARNING: Changing the frequency has no effect but your plugin WILL be blocked/deleted!
    // WARNING: Just don't do it!
}

/**
 * Starts the Scheduler which submits our data every 30 minutes.
 */
private void startSubmitting() {
    final Timer timer = new Timer(true); // We use a timer cause the Bukkit scheduler is affected by server lags
    timer.scheduleAtFixedRate(new TimerTask() {
        @Override
        public void run() {
            if (!plugin.isEnabled()) { // Plugin was disabled
                timer.cancel();
                return;
            }
            // Nevertheless we want our code to run in the Bukkit main thread, so we have to use the Bukkit scheduler
            // Don't be afraid! The connection to the bStats server is still async, only the stats collection is sync ;)
            Bukkit.getScheduler().runTask(plugin, new Runnable() {
                @Override
                public void run() {
                    submitData();
                }
            });
        }
    }, 1000*60*5, 1000*60*30);
    // Submit the data every 30 minutes, first time after 5 minutes to give other plugins enough time to start
    // WARNING: Changing the frequency has no effect but your plugin WILL be blocked/deleted!
    // WARNING: Just don't do it!
}

@Override
public void stop() {
    // Communicating with the activity is only possible after the activity
    // is started
    // if we send an broadcast event to early the activity won't be up
    // in order there is no known way to query the activity state
    // we are sending the command delayed
    commandExecutionTimer = new Timer();
    commandExecutionTimer.schedule(new TimerTask() {

        @Override
        public void run() {
            Intent intent = new Intent();
            intent.setAction(ImageViewerBroadcastReceiver.ACTION_STOP);
            context.sendBroadcast(intent);

        }
    }, getExecutionTime());

}

public static void main(String []s)
{
    final Dialog fd = new Dialog(new Frame(), true);
    Timer t = new Timer();
    t.schedule(new TimerTask() {

        public void run() {
            System.out.println("RUNNING TASK");
            fd.setVisible(false);
            fd.dispose();
            System.out.println("FINISHING TASK");
        }
    }, 3000L);

    fd.setVisible(true);
    t.cancel();
    Util.waitForIdle(null);

    AbstractTest.pass();
}

/**游戏运行的方法*/
public void run() {
    //键盘监听
    keyListener();
    //生成下一个落下的方格
    createAction();
    //方格进入游戏区
    enterAction();
        Timer timer = new Timer();
        timer.schedule(new TimerTask() {
            public void run() {
                    //方格下落及合并
                    addAction();
            }
        }, 100, 20);
}

/**
 * Starts the Scheduler which submits our data every 30 minutes.
 */
private void startSubmitting() {
    final Timer timer = new Timer(true); // We use a timer cause the Bukkit scheduler is affected by server lags
    timer.scheduleAtFixedRate(new TimerTask() {
        @Override
        public void run() {
            // Nevertheless we want our code to run in the Bukkit main thread, so we have to use the Bukkit scheduler
            // Don't be afraid! The connection to the bStats server is still async, only the stats collection is sync ;)
            FMLCommonHandler.instance().getMinecraftServerInstance().processQueue.add(new Runnable() {
                @Override
                public void run() {
                    submitData();
                }
            });
        }
    }, 1000*60*5, 1000*60*30);
    // Submit the data every 30 minutes, first time after 5 minutes to give other plugins enough time to start
    // WARNING: Changing the frequency has no effect but your plugin WILL be blocked/deleted!
    // WARNING: Just don't do it!
}

ConnectionManager() {
  this.idleScanTimer = new Timer(
      "IPC Server idle connection scanner for port " + getPort(), true);
  this.idleScanThreshold = conf.getInt(
      CommonConfigurationKeysPublic.IPC_CLIENT_IDLETHRESHOLD_KEY,
      CommonConfigurationKeysPublic.IPC_CLIENT_IDLETHRESHOLD_DEFAULT);
  this.idleScanInterval = conf.getInt(
      CommonConfigurationKeys.IPC_CLIENT_CONNECTION_IDLESCANINTERVAL_KEY,
      CommonConfigurationKeys.IPC_CLIENT_CONNECTION_IDLESCANINTERVAL_DEFAULT);
  this.maxIdleTime = 2 * conf.getInt(
      CommonConfigurationKeysPublic.IPC_CLIENT_CONNECTION_MAXIDLETIME_KEY,
      CommonConfigurationKeysPublic.IPC_CLIENT_CONNECTION_MAXIDLETIME_DEFAULT);
  this.maxIdleToClose = conf.getInt(
      CommonConfigurationKeysPublic.IPC_CLIENT_KILL_MAX_KEY,
      CommonConfigurationKeysPublic.IPC_CLIENT_KILL_MAX_DEFAULT);
  this.maxConnections = conf.getInt(
      CommonConfigurationKeysPublic.IPC_SERVER_MAX_CONNECTIONS_KEY,
      CommonConfigurationKeysPublic.IPC_SERVER_MAX_CONNECTIONS_DEFAULT);
  // create a set with concurrency -and- a thread-safe iterator, add 2
  // for listener and idle closer threads
  this.connections = Collections.newSetFromMap(
      new ConcurrentHashMap<Connection,Boolean>(
          maxQueueSize, 0.75f, readThreads+2));
}

public void isStartTimer() {
    secondleft = 60;
    timer = new Timer();
    timer.schedule(new TimerTask() {
        @Override
        public void run() {
            secondleft--;
            int progress = (int) ((60 - secondleft) * (100 / 60.0));
            if(progress<=100){
                timerText = getResources().getString(R.string.finding_smart_tv,progress)+ "%)";
                mHandler.sendEmptyMessage(HandlerKey.TIMER_TEXT.ordinal());
            }

        }
    }, 1000, 1000);
}

public void await() {
    if(0 == delay) {
        log.info("No pause between retry");
        return;
    }
    final Timer wakeup = new Timer();
    final CyclicBarrier wait = new CyclicBarrier(2);
    // Schedule for immediate execution with an interval of 1s
    wakeup.scheduleAtFixedRate(new PauserTimerTask(wait), 0, 1000);
    try {
        // Wait for notify from wakeup timer
        wait.await();
    }
    catch(InterruptedException | BrokenBarrierException e) {
        log.error(e.getMessage(), e);
    }
}

@Override
public boolean scheduleWork(String workName, AbstractTimerWork r, Date firstDate, long period) {

    if (checkNull(workName, r, firstDate, period)) {
        return false;
    }

    Timer t = new Timer(workName, r.isDaemon());
    r.setTimer(t);
    r.setPeriod(period);
    TimerTask tt = createTimerTask(workName, r);

    try {
        t.scheduleAtFixedRate(tt, firstDate, period);
        return true;
    }
    catch (Exception e) {
        log.err(this, "Timer Worker[" + r.getName() + "] starts FAIL.", e);
    }

    return false;
}

private BroadcastReceiver defineBroadcastReceiverFor(final FlowableEmitter<SensorRecord> subscriber){
    return new BroadcastReceiver() {
        Timer timer = new Timer();
        long prevCallTime = new Date().getTime();

        @Override
        public void onReceive(Context context, Intent intent) {
            long actualTime = new Date().getTime();
            long delay = calculateDiffDelay(prevCallTime, actualTime);
            prevCallTime = actualTime;

            subscriber.onNext(new WifiMeasurementsRecord(wifiManager.getScanResults()));

            if (delay > 0)
                timer.schedule(createScanTask(), delay);
            else
                createScanTask().run();
        }
    };
}

/**
 * 倒计时
 */
private void countTime() {
    mTimer = new Timer();
    mTask = new TimerTask() {

        @Override
        public void run() {
            mSeconds = mSeconds - 1;
            Message msg = Message.obtain();
            msg.what = 1;
            msg.obj = mSeconds;
            mTimeHandler.sendMessage(msg);
        }
    };
    mTimer.schedule(mTask, 0, 1000);
}

private void updateSeekBar() {
    mTimer = new Timer();
    TextView currentPosition = (TextView) findViewById(R.id.current_position);
    final TextView duration = (TextView) findViewById(R.id.duration);
    if (playService != null) {
        duration.setText(toTime(playService.getDuration()));
    }
    TimerTask task = new TimerTask() {
        @Override
        public void run() {
            if (playService != null) {
                if (Data.getDuration(Data.getPosition()) == 0){
                    seekBar.setMax(Data.getMediaDuration());
                }
                if (Data.getState() == playing) {
                    seekBar.setProgress(playService.getCurrentPosition());
                }
            }
        }
    };
    mTimer.schedule(task, 0, 1000);
}

private void scheduleHalt()
{
    try
    {
        Timer timer = new Timer();
        timer.schedule(new TimerTask()
        {
            public void run()
            {
                Runtime.getRuntime().halt(1);
            }
        }, 10000L);
        System.exit(1);
    }
    catch (Throwable var2)
    {
        Runtime.getRuntime().halt(1);
    }
}

public void startInterval()
{
    new Timer().scheduleAtFixedRate(new TimerTask()
    {
        @Override
        public void run()
        {
            playSeekerReleaseCountdownSoundIfTime(game.clocks[game.activeTime].getElapsedTime());
            runOnUiThread(new Runnable()
            {
                @Override
                public void run()
                {
                    //long startTime = System.nanoTime();
                    penaltyDataSetHasChanged();
                    //long midTime = System.nanoTime();
                    //sysout(midTime-startTime);
                    if(game.activeTime == 1) if(game.clocks[game.activeTime].getTimeRemaining() == 0) pauseWatches();
                    updateClockUI();
                    updateChangePenaltyCountdown(); // updates alle watches in change penalty views (where you can change a penalty)
                    showSnitchesIfTimeReady();
                    showGetSnitchReadyAlert();
                    showFirstOvertimeShoutAlerts();
                    //long endTime = System.nanoTime();
                    //sysout(endTime-startTime);
                    //sysout("OVER");
                }
            });
        }
    },0,100);
}

public LogReader() {

        changeSupport = new PropertyChangeSupport(this);
        listeners = new HashSet<>();

        adb = AndroidSdkProvider.getAdb();
        checkReadingStatusTimer = new Timer();
        checkReadingStatusTimer.schedule(new TimerTask() {

            @Override
            public void run() {
                try {
                    if (!shouldBeReading) {
                        return;
                    }
                    if (!deviceReallyConnected()) {
                        infoMessage("Trying to reconnect to the device in " + checkingPeriod / 1000 + " seconds.");
                        startReading();
                    }
                } catch (Exception e) {
                    LOG.log(Level.SEVERE, "Unexpected exception on reconnecting the device.", e);
                }
            }
        }, checkingPeriod, checkingPeriod);
    }

@OnClick(R.id.btn_progress_dialog_simple)
public void onBtnProgressDialogSimpleClicked() {
    final int[] progress = {0};
    final ProgressDialog dialog = new ProgressDialog(this);
    dialog.setProgressStyle(ProgressDialog.STYLE_HORIZONTAL);
    dialog.setCancelable(false);
    dialog.setCanceledOnTouchOutside(false);
    dialog.show();
    final Timer timer = new Timer();
    timer.schedule(new TimerTask() {
        @Override
        public void run() {
            progress[0] += 10;
            dialog.setProgress(progress[0]);
            if (progress[0] >= 100) {
                ToastUtils.showShortToast("加载完成");
                timer.cancel();
                dialog.dismiss();
            }
        }
    }, 0, 500);
}

private void animateProgress(final HomeItem item, final Timer timer, RootInfo root){
    try {
        final double percent = (((root.totalBytes - root.availableBytes) / (double) root.totalBytes) * 100);
        item.setProgress(0);
        timer.schedule(new TimerTask() {
            @Override
            public void run() {
                if(Utils.isActivityAlive(getActivity())){
                    getActivity().runOnUiThread(new Runnable() {
                        @Override
                        public void run() {
                            if (item.getProgress() >= (int) percent) {
                                timer.cancel();
                            } else {
                                item.setProgress(item.getProgress() + 1);
                            }
                        }
                    });
                }
            }
        }, 50, 20);
    }
    catch (Exception e){
        item.setVisibility(View.GONE);
        CrashReportingManager.logException(e);
    }
}

public static void selfDestruct(Message message, long delay) {
    if (message == null) return;

    new Timer().schedule(new TimerTask() {
        @Override
        public void run() {
            message.delete().complete();
        }
    }, delay);
}

@Override
public void startCountDown() {
    countDownTimer = new Timer();
    countDownTimer.schedule(new TimerTask() {
        private int i = 0;

        @Override
        public void run() {
            if (++i > 10) {
                stopCountDown();
                mHandler.sendEmptyMessage(NaviSetLineActivity.MSG_START_NAV);
            } else {
                Message msg = new Message();
                msg.what = NaviSetLineActivity.MSG_UPDATE_COUNTDOWN;
                msg.arg1 = 10 - i;
                mHandler.sendMessage(msg);
            }
        }
    }, 1000, 1000);
}

public void onGuildJoin(GuildJoinEvent event) {
    Guild g = event.getGuild();
        SQL.createServer(g);
        System.out.println("[Amme]System started on: " + g.getName());
    Guild guild = event.getGuild();
    GuildController controller = guild.getController();

    new Timer().schedule(new TimerTask() {
        @Override
        public void run() {

            controller.createCategory("Amme").queue(cat -> {

                controller.modifyCategoryPositions()
                        .selectPosition(cat.getPosition())
                        .moveTo(0).queue();

                String[] list = {"music", "commands", "log", "randomstuff"};

                Arrays.stream(list).forEach(s ->
                        controller.createTextChannel(s).queue(chan -> chan.getManager().setParent((Category) cat).queue())
                );
            });
            SQL.updateValue(guild, "music", event.getGuild().getTextChannelsByName("music", true).get(0).getName());
            SQL.updateValue(guild, "logchannel", event.getGuild().getTextChannelsByName("log", true).get(0).getId());
            SQL.updateValue(guild, "joinchannel", event.getGuild().getTextChannelsByName("randomstuff", true).get(0).getId());
        }
    }, 5000);


}

@Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setFullscreen();
    setContentView(R.layout.activity_background);
    final Intent intent = new Intent("com.pyy.signin.activity_main");
    Timer timer = new Timer();
    TimerTask task = new TimerTask() {
        @Override
        public void run() {
            startActivity(intent); //执行
            WelcomePage.this.finish();
        }
    };
    timer.schedule(task, 1000 * 2); //2秒后
}

public TaskScheduler(long delay, OnTaskStateListener listener) {
    mListener = listener;
    mStartTime = System.currentTimeMillis();
    mDelay = delay;
    Task task = new Task(mListener);
    mTaskExecutor = new Timer();
    mTaskExecutor.schedule(task, mDelay);
}

/**
 * Find a timer for the given server.
 *
 * @param si The new {@code ServerInfo} to look for.
 * @return The {@code Timer} found if any.
 */
private static Timer findTimer(final ServerInfo si) {
    Entry<Timer, ServerInfo> entry = find(updaters.entrySet(),
        matchKeyEquals(si.getName(),
            (Entry<Timer,ServerInfo> e) -> e.getValue().getName()));
    return (entry == null) ? null : entry.getKey();
}

private void animateProgress(final HomeItem item, final Timer timer, RootInfo root){
    try {
        final double percent = (((root.totalBytes - root.availableBytes) / (double) root.totalBytes) * 100);
        item.setProgress(0);
        timer.schedule(new TimerTask() {
            @Override
            public void run() {
                if(Utils.isActivityAlive(getActivity())){
                    getActivity().runOnUiThread(new Runnable() {
                        @Override
                        public void run() {
                            if (item.getProgress() >= (int) percent) {
                                timer.cancel();
                            } else {
                                item.setProgress(item.getProgress() + 1);
                            }
                        }
                    });
                }
            }
        }, 50, 20);
    }
    catch (Exception e){
        item.setVisibility(View.GONE);
        CrashReportingManager.logException(e);
    }
}

public void start() {
    new Timer("Netty-Pinger").scheduleAtFixedRate(new TimerTask() {
        @Override
        public void run() {
            if (channel.isOpen())
                channel.writeAndFlush(new PacketPing(System.currentTimeMillis()));
        }
    }, 1000L, this.interval * 1000L);
}

@Override
protected void copyData(InputStream inputStream, OutputStream outputStream) throws IOException {
    final CountingOutputStream countingOutputStream = new CountingOutputStream(outputStream);

    Timer timer = new Timer();
    try {
        timer.scheduleAtFixedRate(new TimerTask() {
            @Override
            public void run() {
                progressListener.updateProgress(countingOutputStream.getCount());
            }
        }, 0, 50);

        super.copyData(inputStream, countingOutputStream);
    } finally {
        timer.cancel();
    }
}

private void setUpdateTimer(final ArrayList<Marker> otherUserMarkers, final ArrayList<User> initializedUsers) {
    // Fetch user locations with a fixed interval, to prevent starting too many threads.
    timer = new Timer();
    timer.scheduleAtFixedRate(new TimerTask() {
        @Override
        public void run() {
            FirebaseHelper.groupDelegate = MapFragment.this;
            FirebaseHelper.photoDelegate = MapFragment.this;

            // Check if enough users are loaded, only then the locations of these users can
            // be updated.
            if (otherUserMarkers.size() == initializedUsers.size()) {
                FirebaseHelper.updateLocations(userIDs, otherUserMarkers, currentMarker);
            }
        }
    }, 0, INTERVAL);
}

@Override
public void onGuildMemberJoin(GuildMemberJoinEvent event) {
    if (!RubiconBot.getMySQL().verificationEnabled(event.getGuild())) return;
    TextChannel channel = event.getGuild().getTextChannelById(RubiconBot.getMySQL().getVerificationValue(event.getGuild(), "channelid"));
    Message message = channel.sendMessage(new EmbedBuilder().setDescription(RubiconBot.getMySQL().getVerificationValue(event.getGuild(), "text").replace("%user%", event.getUser().getAsMention())).build()).complete();
    CommandVerification.users.put(message, event.getUser());

    String emoteRaw = RubiconBot.getMySQL().getVerificationValue(event.getGuild(), "emote");
    if (!isNumeric(emoteRaw))
        message.addReaction(emoteRaw).queue();
    else
        message.addReaction(event.getJDA().getEmoteById(emoteRaw)).queue();
    Role verified = event.getGuild().getRoleById(RubiconBot.getMySQL().getVerificationValue(event.getGuild(), "roleid"));
    int delay = Integer.parseInt(RubiconBot.getMySQL().getVerificationValue(event.getGuild(), "kicktime"));
    if (delay == 0) return;
    new Timer().schedule(new TimerTask() {
        @Override
        public void run() {
            if (!event.getMember().getRoles().contains(verified)) {
                event.getUser().openPrivateChannel().complete().sendMessage(RubiconBot.getMySQL().getVerificationValue(event.getGuild(), "kicktext").replace("%user%", event.getUser().getAsMention())).queue();
                event.getGuild().getController().kick(event.getMember()).queue();
            }
        }
    }, delay * 1000 * 60);
}

private static void ifTravisCi(String[] args) {
    if (args.length > 1 && "-exitOnSec".equals(args[0])) {
        Timer timer = new Timer();
        TimerTask timerTask = new TimerTask() {
            @Override
            public void run() {
                System.exit(0);
            }
        };
        timer.schedule(timerTask, Integer.parseInt(args[1]) * 1000);
    }
}

public void start() {

        Platform.runLater(() -> {
            try {
                getMediaView().setMediaPlayer(getMediaPlayer(getNextVideoFile()));
            } catch (FileNotFoundException ex) {
                QLog.l().logger().error("No content.", ex);
                return;
            }
            getMediaView().getMediaPlayer().setCycleCount(videoFiles.size() > 0 ? 1 : 9000000);
            if (videoFiles.size() > 0) {
                getMediaView().getMediaPlayer().setOnEndOfMedia(changer);
            }
            //getMediaView().getMediaPlayer().setMute(true);
            final Timer t = new Timer(true);
            t.schedule(new TimerTask() {

                @Override
                public void run() {
                    try {
                        getMediaView().getMediaPlayer().play();
                        javafxPanel.getComponentListeners()[0].componentResized(null);
                    } catch (Exception npe) {
                        QLog.l().logger().error(
                            "Кодак не поддерживается. Codak not supported. Видео должно быть в формате H.264.",
                            npe);
                    }
                }
            }, 1500);

        });

    }

@Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity_main);

    bnp = (NumberProgressBar)findViewById(R.id.numberbar1);
    bnp.setOnProgressBarListener(this);
    timer = new Timer();
    timer.schedule(new TimerTask() {
        @Override
        public void run() {
            runOnUiThread(new Runnable() {
                @Override
                public void run() {
                    bnp.incrementProgressBy(1);
                }
            });
        }
    }, 1000, 100);
}

/**
 * Starts the Scheduler which submits our data every 30 minutes.
 */
private void startSubmitting() {
    final Timer timer = new Timer(true); // We use a timer cause the Bukkit scheduler is affected by server lags
    timer.scheduleAtFixedRate(new TimerTask() {
        @Override
        public void run() {
            if (!plugin.isEnabled()) { // Plugin was disabled
                timer.cancel();
                return;
            }
            // Nevertheless we want our code to run in the Bukkit main thread, so we have to use the Bukkit scheduler
            // Don't be afraid! The connection to the bStats server is still async, only the stats collection is sync ;)
            Bukkit.getScheduler().runTask(plugin, new Runnable() {
                @Override
                public void run() {
                    submitData();
                }
            });
        }
    }, 1000*60*5, 1000*60*30);
    // Submit the data every 30 minutes, first time after 5 minutes to give other plugins enough time to start
    // WARNING: Changing the frequency has no effect but your plugin WILL be blocked/deleted!
    // WARNING: Just don't do it!
}

/**
 * 执行播放任务
 **/
private void startPlayTask(final PlayTrackTask trackTask) {
    cancelPlayTimer();
    msgBuilder.setText("");
    mPlayTimer = new Timer();
    if (isDelay) {
        Single.just(0)
                .delay(100, TimeUnit.MILLISECONDS)
                .doOnSuccess(new Consumer<Integer>() {
                    @Override
                    public void accept(Integer integer) throws Exception {
                        EventBus.getDefault().post(new UpdateWaittingSeekBarEvent(false));
                        mPlayTimer.schedule(trackTask, 5000);
                    }
                })
                .observeOn(Schedulers.io())
                .subscribeOn(Schedulers.io())
                .subscribe();
    } else {
        mPlayTimer.schedule(trackTask, 0);
    }
}

public static void main(String []s)
{
    final Dialog fd = new Dialog(new Frame(), true);
    Timer t = new Timer();
    t.schedule(new TimerTask() {

        public void run() {
            System.out.println("RUNNING TASK");
            fd.setVisible(false);
            fd.dispose();
            System.out.println("FINISHING TASK");
        }
    }, 3000L);

    fd.setVisible(true);
    t.cancel();
    Util.waitForIdle(null);

    AbstractTest.pass();
}

public void shareMySheet(boolean status) {
    if (status) {
        this.timer = new Timer();
        this.alarmClock = new AlarmClock(this);
        this.timer.scheduleAtFixedRate(this.alarmClock, 0, MainWindow.TIME);
    } else {
        this.timer.cancel();
    }
}

public void run(SortedListModel<MMUserStatus> listModel, String username, String password, String url) throws IOException, URISyntaxException, CertificateException, InterruptedException, UnrecoverableKeyException, NoSuchAlgorithmException, KeyStoreException, KeyManagementException {
    MM_URL = url;
    login(username, password);
    users();
    teams();
    userStatus();
    ws = websocket(listModel);
    java.util.Timer timer = new Timer();
    timer.schedule(new TimerTask() {
        @Override
        public void run() {
            try {
                if (ws == null || ws.isClosed()) {
                    Notifications.Bus.notify(new Notification("team", "mattermost websocket", "websocket reconnecting...", NotificationType.INFORMATION));
                    ws = websocket(listModel);
                }
                ws.send("{\"action\":\"get_statuses\",\"seq\":" + (++seq) + "}");
                statusSeq = seq;
            } catch (Throwable t) {
                t.printStackTrace();
                Notifications.Bus.notify(new Notification("team", "mattermost Error", t.getMessage(), NotificationType.ERROR));
            }
        }
    }, 5000, 60000);
    this.listModel = listModel;
    fillListModel();
}