标签: blocking

我的公司被共生伙伴关系所诅咒变成了寄生虫.为了从寄生虫获取我们的数据,我们必须使用非常缓慢的odbc连接.我最近注意到,虽然我可以通过并行运行查询来获得更多的吞吐量(即使在同一个表上).

有一个特别大的表,我想从中提取数据并将其移动到我们的本地表中.并行运行查询我可以更快地获取数据,但我也想象这可能会导致尝试将多个查询中的数据一次写入同一个表时出现问题.

您可以给我什么建议,以便最好地处理这种情况,以便我可以利用并行使用查询的速度提高？

编辑:我在这里得到了一些很好的反馈,但我想我并不完全清楚我通过链接服务器(使用odbc驱动程序)提取数据.换句话说,这意味着我可以运行正常的INSERT语句,我相信这将提供比SqlBulkCopy或BULK INSERT更好的性能(实际上,我不相信BULK INSERT甚至可以选择).

关于将套接字设置为非阻塞模式,我已经读过这个.

http://www.gnu.org/software/libc/manual/html_mono/libc.html#File-Status-Flags

这是我做的:

static void setnonblocking(int sock)
{
    int opts;

    opts = fcntl(sock,F_GETFL);
    if (opts < 0) {
        perror("fcntl(F_GETFL)");
        exit(EXIT_FAILURE);
    }
    opts = (opts | O_NONBLOCK);
    if (fcntl(sock,F_SETFL,opts) < 0) {
        perror("fcntl(F_SETFL)");
        exit(EXIT_FAILURE);
    }
    return;
}

如何将套接字设置回阻止模式？我没有看到O_BLOCK标志？

谢谢.

假设我想在一定时间内阻止Javascript执行出于某种奇怪的原因,我该怎么做呢.JS中没有sleep().请不要说做while()循环,因为那很糟糕.我可以做一个window.showModalDialog并在一个非常小的时间的setTimeout的模态对话框中放置一个window.close,这样用户就不会注意到该对话框.这就像睡眠一段时间,如果需要我可以多次调用.还有其他方法吗？

详细说明,我的用例是HTML5 SQL数据库已经给出了异步api,但我想将它用于一个小商店永远不会大的小型webapp.因此不需要异步api,因为小商店上的查询将在客户端运行.所以我想编写一个带有sync api的ORM,以便开发人员可以更轻松地使用它.要将此异步桥接到同步api,我需要像睡眠这样的东西.

所以我想做很多 DNS查询.

我从Begin/EndGetHostEntry异步对中创建了(数千个)任务:

var lookupTask = Task.Factory.FromAsync
   ( Dns.BeginGetHostEntry,
     (Func<IAsyncResult, IPHostEntry>) Dns.EndGetHostEntry,
     "google.com", 
     null
   )

然后Task.WaitAll一切都要完成.我看到ThreadPool响应我的请求,线程数量急剧增加.如果我强制ThreadPool minThreads转到500,则工作量的消耗会大大加快.所有这些都指向Dns异步实现中的阻塞.

如果我Dns用托管Dns客户端替换,我可以消耗相同的工作负载,只有1或2个线程在ThreadPoolcpu中几乎空闲.

问题是,在Dns实现绝对核心,许多网络API( ,HttpWebRequest,WebClient),HttpClient他们似乎都受到这个问题的影响.如果我使用第三方库解析DNS,并使用IP地址作为uri中的主机发出HTTP请求,则更改Host标头以修复请求,与任何涉及的内容相比,我的性能都很高System.Net.Dns.

这里发生了什么？我错过了什么或者System.Net.Dns实施真的那么糟糕吗？

我的MySQL数据库提供三个webapps作为存储后端.但是我最近遇到了错误"等待表元数据锁".它几乎一直发生,我不明白为什么.

mysql> show processlist
    -> ;
+------+-----------+-----------------+------------+---------+------+---------------------------------+------------------------------------------------------------------------------------------------------+
| Id   | User      | Host            | db         | Command | Time | State                           | Info                                                                                                 |
+------+-----------+-----------------+------------+---------+------+---------------------------------+------------------------------------------------------------------------------------------------------+
|   36 | root      | localhost:33444 | bookmaker2 | Sleep   |  139 |                                 | NULL                                                                                                 |
|   37 | root      | localhost:33445 | bookmaker2 | Sleep   |  139 |                                 | NULL                                                                                                 |
|   38 | root      | localhost:33446 | bookmaker2 | Sleep   |  139 |                                 | NULL                                                                                                 |
|   39 | root      | localhost:33447 | …

我正在Rust中创建一个小的ncurses应用程序,需要与子进程通信.我已经有了一个用Common Lisp编写的原型; 这里的gif 将有希望展示我想做的事情.我正在尝试重写它,因为CL为这么小的工具使用了大量的内存.

我之前没有使用过Rust(或其他低级语言),而且我在弄清楚如何与子进程交互时遇到了一些麻烦.

我目前正在做的大致是这样的:

1. 创建流程:

   let mut program = match Command::new(command)
       .args(arguments)
       .stdin(Stdio::piped())
       .stdout(Stdio::piped())
       .stderr(Stdio::piped())
       .spawn()
   {
       Ok(child) => child,
       Err(_) => {
           println!("Cannot run program '{}'.", command);
           return;
       }
   };
   

   Run Code Online (Sandbox Code Playgroud)

2. 将它传递给无限(直到用户退出)循环,该循环读取并处理输入并像这样监听输出(并将其写入屏幕):

   fn listen_for_output(program: &mut Child, output_viewer: &TextViewer) {
       match program.stdout {
           Some(ref mut out) => {
               let mut buf_string = String::new();
               match out.read_to_string(&mut buf_string) {
                   Ok(_) => output_viewer.append_string(buf_string),
                   Err(_) => return,
               };
           }
           None => return,
       };
   }
   

   Run Code Online (Sandbox Code Playgroud)

read_to_string然而,调用阻止程序直到进程退出.从我所看到的read_to_end,read似乎也阻止.如果我尝试运行类似于ls哪个退出的东西,它可以工作,但是有些东西不能退出, …

在计算的同步/阻塞模型中,我们通常说执行线程在等待IO任务完成时将等待(被阻塞).

我的问题是,这通常会导致CPU核心执行线程空闲,还是等待IO的线程通常会被上下文切换出来并进入等待状态,直到IO准备好被处理？

如果我在插入/更新后在PostgreSQL中设置AFTER触发器,那么调用软件是否必须等待触发器完成才能将控制权返回给调用软件？或者触发器会在幕后自行运行吗？

我在文件系统库中看到了很多同步函数.如fs.readFileSync(filename, [options]).

如果节点具有异步/非阻塞IO并且没有睡眠方法,那么如何(以及为什么)实现这些功能 - 我可以使用相同的机制来实现其他同步功能吗？

我调试我的应用程序时遇到此问题.它在这条线上阻挡,我不知道是什么造成的.我找不到任何答案或任何有同样问题的人.我不知道代码的哪一部分会导致这种情况发生.你对此有什么想法或经验吗？我正在使用 Android Studio 3.1, JRE 1.8.0, JVM: OpenJDK 64-bit