免费注册 查看新帖 |

Chinaunix

  平台 论坛 博客 文库
最近访问板块 发新帖
查看: 4368 | 回复: 5
打印 上一主题 下一主题

多线程共享数据库连接句柄的问题 [复制链接]

论坛徽章:
0
跳转到指定楼层
1 [收藏(0)] [报告]
发表于 2006-12-06 22:19 |只看该作者 |倒序浏览
perl的多线程似乎不支持共享数据库的连接句柄,有什么办法能让线程共享此句柄呢?我试过clone方法,拷贝了句柄并在线程中使用。

  1. my $dbcp=clone($dbh);
  2. my $thr=threads->create('insert');
  3. sub insert{
  4.         my $rows=$dbcp->do("insert into testaa values(20000,6)");
  5.         my $tid=threads->self->tid;
  6.         print "thread $tid insert $rows rows\n";
  7. }
复制代码

但运行返回错误:
Can't call do method on handle DBI::db=HASH(0x86af814) after take_imp_data()
这是什么原因造成的?还有其他方法解决这个问题吗?总不能每个线程都创建连接句柄吧。

论坛徽章:
1
荣誉会员
日期:2011-11-23 16:44:17
2 [报告]
发表于 2006-12-06 22:45 |只看该作者
你的问题..我也碰过...
这也是为什麽我放弃用multithread改用multiprocess的原因之一.....

论坛徽章:
0
3 [报告]
发表于 2006-12-07 10:25 |只看该作者
难道线程下就没有好的解决办法了吗?因为fork数的上限问题,我还是想用线程处理问题。

论坛徽章:
0
4 [报告]
发表于 2006-12-08 02:19 |只看该作者
Clone是不行的,我是每个线程新建一个连接。

论坛徽章:
0
5 [报告]
发表于 2006-12-11 13:52 |只看该作者
一定要每个线程交叉操作数据库吗?
为何不变通一下, 单独一个线程用来处理所有的数据库操作呢?

例如:


  1. use threads;
  2. use threads::shared;
  3. use Thread::Queue::Any;

  4. our $Queue = Thread::Queue::Any->new();

  5. threads->create('thread_db')->detach;
  6. threads->create('thread_worker')->detach;

  7. sub thread_db
  8. {
  9.     eval 'use DBI';
  10.     my $dbh = DBI->connect(...);
  11.     while (my $do = $Queue->dequeue()) {
  12.           $dbh->do($do);
  13.     }
  14. }

  15. sub thread_worker
  16. {
  17.      my $sql = 'insert into testaa values(20000,6)';
  18.      $Queue->enqueue($sql);
  19. }

复制代码

论坛徽章:
0
6 [报告]
发表于 2006-12-21 13:09 |只看该作者
楼上的方法不错,但如果是要获得查询结果集的场合,处理起来就要复杂多了,还得分配结果集给相应的线程……
您需要登录后才可以回帖 登录 | 注册

本版积分规则 发表回复

  

北京盛拓优讯信息技术有限公司. 版权所有 京ICP备16024965号-6 北京市公安局海淀分局网监中心备案编号:11010802020122 niuxiaotong@pcpop.com 17352615567
未成年举报专区
中国互联网协会会员  联系我们:huangweiwei@itpub.net
感谢所有关心和支持过ChinaUnix的朋友们 转载本站内容请注明原作者名及出处

清除 Cookies - ChinaUnix - Archiver - WAP - TOP