标签: polling

我正在开发一个 Apple TV 应用程序，该应用程序使用 Parse-Server 作为后端和 RxSwift，并且我正在尝试建立一个类似于电视流媒体应用程序上的身份验证系统。

现在，我在解析数据库中有一个 AuthenticationCode 对象，其中包含代码、设备 ID 和会话令牌列。我正在尝试使用 RxSwift 的间隔每 5 秒对对象执行一次获取，并检查会话令牌列是否已填写。

这是代码：

func poll(authorizationCode: AuthorizationCode) -> Observable<AuthorizationCode> {
    return Observable<Int>.interval(5, scheduler: MainScheduler.instance).flatMap({ _ in
        return Observable<AuthorizationCode>.create { observer -> Disposable in
            authorizationCode.fetchInBackground(block: { (authorizationCode, error) in
                if let authorizationCode = authorizationCode as? AuthorizationCode {
                    observer.onNext(authorizationCode)

                    if authorizationCode.sessionToken != nil {
                        observer.onCompleted()
                    }
                } else if let error = error {
                    observer.onError(error)
                }
            })

            return Disposables.create()
        }
    })
}

每次获取对象时，我都会发出 onNext 事件，并且我想在会话代码存在时终止序列。

我在这段代码中遇到的问题是，即使在填写了会话令牌并调用了 onCompleted 之后，计时器仍然会触发，并且订阅者永远不会获得 onCompleted …

PollListenerVaadin 14 中是否有可能删除 a ？

UI.getCurrent().addPollListener(pollEvent -> { refresh(); }

我需要开始刷新，但如果路由或 UI 发生更改，刷新必须停止。

是否有“Vaadin 可能性”，或者我必须自己构建一些东西？

谢谢你！

我的项目需要使用AJAX轮询JSON响应的某个URL.我发出的第一个AJAX请求警告服务器我想要一些JSON内容,它开始构建和缓存响应,为每个后续的AJAX请求发回{{status":"pending"},直到JSON准备好.此时,响应更改为JSON,其中包含我可以解析并显示在文档中的内容,一旦URL返回除{"status":"pending"}之外的任何内容,我想要执行此操作.

我已经设置了一个轮询函数,它按预期工作,从URL反复请求JSON.但问题是,即使我直接导航到URL并且可以看到完整的JSON响应已准备好并正在提供服务,它仍会继续获得响应{"status":"pending"}.出于某种原因,我的轮询功能仍然是{"status":"pending"}.

当我刷新包含轮询代码的页面时,它通常适用于第一个请求 - 即它获得完整的JSON响应.这让我相信它是某种缓存问题,但我不确定在哪里或为何.不应该每个AJAX请求得到一个新的响应,或者这是我可以在我的$ .ajax()调用中设置的东西？

这是我现在使用的代码:

function ajax_poll() {
  $.ajax({
    url: JSON_URL, // JSON_URL is a string containing the URL to poll
    dataType: 'json',
    error: function(xhr_data) {
      display_error();
    },
    success: function(xhr_data) {
      if (xhr_data.status == 'pending') {
        poll++; // increment poll counter // poll is a global variable to track the number of requests made
        if (poll < POLLS) { // POLLS is a global variable to set the …

有没有更优雅的方式去做我在下面做的事情？也就是说,是否有比轮询和睡眠,轮询和睡眠更优雅的方式,等等,以便知道何时Runnable.run()通过调用方法invokeLater()？

private int myMethod() {
    final WaitForEventQueue waitForQueue = new WaitForEventQueue();
    EventQueue.invokeLater(waitForQueue);
    while (!waitForQueue.done) {
        try {
            Thread.sleep(10);
        } catch (InterruptedException ignore) {
        }
    }

    return 0;
}

private class WaitForEventQueue implements Runnable {
    private boolean done;

    public void run() {
        // Let all Swing text stuff finish.
        done = true;
    }
}

首先,让我说我不是Visual Basic 6专家......

我的需要是:

• 从VB6客户端代码启动一个exeternal .exe文件
• 等待进程完成 - 在执行期间 - "动态"读取来自其标准输出的消息(以便我可以在文本提交的小部件或类似物上打印).

我想知道是否有可能在VB6中这样做...在互联网上长时间搜索后我没有想出任何东西.找到了很多关于如何使用该Shell函数的例子,但它似乎迫使我在进程执行结束时一次性读取stdout,但是我想在流程中查看"新鲜"消息,因为它们变得可用.

任何代码片段/建议/参考都非常感谢.

提前致谢!

我编写了一个C程序来轮询目录中的文件,但是在尝试访问该文件时有时会出错.我想知道在尝试使用它之前是否需要等待它完成复制或其他什么？我设置了一个循环来继续加载图像文件,直到函数不再返回null:

while (  (image = SDL_LoadBMP(path)) == NULL  )
    printf("image = NULL\n");

最终它不再是空的.处理这个问题的正确方法是什么？

poll()的文档没有详细解释这一点.在fd上轮询时,应该在何时使用POLLIN和何时使用POLLPRI？任何见解都会很有用.

我正在寻找一个关于使用AngularJS轮询数据的解决方案,我在stackoverflow找到了这里.

在这个解决方案(如下图所示)中,它使用一个javascript对象来返回response(data.response),如果我尝试将该data对象替换为一个简单的javascript数组它不起作用,我想知道为什么我需要去点符号以及为什么单个数组不起作用？(这将是很好的链接或解释与示例)

app.factory('Poller', function($http, $timeout) {
  var data = { response: {}, calls: 0 };
  var poller = function() {
    $http.get('data.json').then(function(r) {
      data.response = r.data;
      data.calls++;
      $timeout(poller, 1000);
    });      
  };
  poller();

  return {
    data: data
  };
});

试图总结我的目标(我想真正了解):哪里是var data = { response: {}, calls: 0 };可以var data = {};,然后response.data就可以直接设置好的数据data = r.data和 return {data: data};,为什么我需要靠点符号？

我正在使用primefaces 5.0开发jsf，如果在后备bean中满足条件，我需要将用户重定向到另一个页面。因此，我习惯于p:poll让页面每秒检查一次条件，如果满足条件，则将用户重定向到另一个页面。

我创建了一个小项目来尝试这种情况，该项目使用poll来检查是否int cnt大于等于10，如果是，则将用户重定向到welcomePrimefaces.xhtml。另外，还有另一个线程T1用于简单地增加线程数，cnt以便该条件可以满足一段时间。

这是我做的事情：
页面：（没什么特别的，只需每秒轮询一次即可查看状态）

<h:form>
    Hello from Facelets
    <br />
    <p:poll interval="1" listener="#{mainBean.checkStatus()}"/>
</h:form>

后备豆：

public class MainBean {

    private Integer cnt = 0;

    @PostConstruct
    public void init() {
        Thread t1 = new Thread(new T1(), "test");
        t1.start();

    }

    public void checkStatus() {
        synchronized (cnt) {
            System.out.println("cnt:" + cnt);
            if (cnt >= 10) {
                try {
                    Object request = FacesContext.getCurrentInstance().getExternalContext().getRequest();
                    Object response = FacesContext.getCurrentInstance().getExternalContext().getResponse();
                    HttpServletRequest httpRequest = (HttpServletRequest) …

这是我第一次使用文件描述符进行读取，并且我已经通过反复试验进行了大约3个小时的测试，而我的读取器几乎可以正常工作！我只需要一点帮助来检查命名管道上的EOF。

好的，这样我就可以打开一个（多个）命名管道：

fds[j].fd = open(pipeNameo, O_RDWR) ; // storing it into my file descriptor array

然后我在轮询命名管道以查看是否发生了任何事情（轮询在循环内）：

int ret = poll(fds, numOfPipesUsed, timeout_msecs);

当确实发生问题时，我通过发送写入该函数的文件描述符来处理文件：

int processFileDes( int fd )
{
    char buf[10] ;

    read(fd, buf, 1) ;
    char curr = buf[0] ;
    while (curr != EOF)
    {

        if ( curr == ' ')
        {
            // do nothing it is a space
        }
        else if ( curr == '\n')
        {
            printf("NEW LINE!\n") ;
        }
        else
        {
            int num = curr - '0' …