小网点也有大作为_小也有大作为

小网点也有大作为_小也有大作为在namespacePetShop.OrderProcessor.Program的代码中:1//thetransactiontimeoutshouldbelongenoughtohandleallofordersinthebatch2TimeSpantsTimeout=TimeSpan.FromSeconds(Conve…

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE稳定放心使用

在namespace PetShop.OrderProcessor.Program 的代码中:

 1
小网点也有大作为_小也有大作为
 
//
 the transaction timeout should be long enough to handle all of orders in the batch


 2
小网点也有大作为_小也有大作为
            TimeSpan tsTimeout 
=
 TimeSpan.FromSeconds(Convert.ToDouble(transactionTimeout 
*
 batchSize));

 3
小网点也有大作为_小也有大作为

 4
小网点也有大作为_小也有大作为            Order order 
=
 
new
 Order();

 5
小网点也有大作为_小也有大作为小网点也有大作为_小也有大作为            
while
 (
true

小网点也有大作为_小也有大作为
{

 6小网点也有大作为_小也有大作为
 7小网点也有大作为_小也有大作为                // queue timeout variables
 8小网点也有大作为_小也有大作为                TimeSpan datetimeStarting = new TimeSpan(DateTime.Now.Ticks);
 9小网点也有大作为_小也有大作为                double elapsedTime = 0;
10小网点也有大作为_小也有大作为
11小网点也有大作为_小也有大作为                int processedItems = 0;
12小网点也有大作为_小也有大作为
13小网点也有大作为_小也有大作为                ArrayList queueOrders = new ArrayList();
14小网点也有大作为_小也有大作为
15小网点也有大作为_小也有大作为                //OrderInfo orderData = orderQueue.Receive(timeout);
16小网点也有大作为_小也有大作为小网点也有大作为_小也有大作为                using (TransactionScope ts = new TransactionScope(TransactionScopeOption.Required, tsTimeout)) 小网点也有大作为_小也有大作为{

17小网点也有大作为_小也有大作为                   // Console.WriteLine(“begin.at:” + DateTime.Now.ToString());
18小网点也有大作为_小也有大作为                    // Receive the orders from the queue
19小网点也有大作为_小也有大作为小网点也有大作为_小也有大作为                    for (int j = 0; j < batchSize; j++小网点也有大作为_小也有大作为{

20小网点也有大作为_小也有大作为                       // Console.WriteLine(“从消息队列中取数据.at:” + DateTime.Now.ToString());
21小网点也有大作为_小也有大作为
22小网点也有大作为_小也有大作为小网点也有大作为_小也有大作为                        try 小网点也有大作为_小也有大作为{

23小网点也有大作为_小也有大作为                            //only receive more queued orders if there is enough time
24小网点也有大作为_小也有大作为小网点也有大作为_小也有大作为                            if ((elapsedTime + queueTimeout + transactionTimeout) < tsTimeout.TotalSeconds) 小网点也有大作为_小也有大作为{

25小网点也有大作为_小也有大作为                                //Console.WriteLine(string.Format(“从消息队列中取数据.at:{0},{1},{2},{3},{4}”, DateTime.Now.ToString(), elapsedTime, queueTimeout, transactionTimeout, tsTimeout.TotalSeconds));
26小网点也有大作为_小也有大作为                                queueOrders.Add(order.ReceiveFromQueue(queueTimeout));
27小网点也有大作为_小也有大作为                                
28小网点也有大作为_小也有大作为                            }

29小网点也有大作为_小也有大作为小网点也有大作为_小也有大作为                            else 小网点也有大作为_小也有大作为{

30小网点也有大作为_小也有大作为                                j = batchSize;   // exit loop
31小网点也有大作为_小也有大作为                            }

32小网点也有大作为_小也有大作为
33小网点也有大作为_小也有大作为                            //update elapsed time
34小网点也有大作为_小也有大作为                            elapsedTime = new TimeSpan(DateTime.Now.Ticks).TotalSeconds  datetimeStarting.TotalSeconds;
35小网点也有大作为_小也有大作为                        }

36小网点也有大作为_小也有大作为小网点也有大作为_小也有大作为                        catch (TimeoutException) 小网点也有大作为_小也有大作为{

37小网点也有大作为_小也有大作为
38小网点也有大作为_小也有大作为                            //exit loop because no more messages are waiting
39小网点也有大作为_小也有大作为                            j = batchSize;
40小网点也有大作为_小也有大作为                            //Console.WriteLine(“TimeoutException.at:” + DateTime.Now.ToString());
41小网点也有大作为_小也有大作为                        }

42小网点也有大作为_小也有大作为                    }

43小网点也有大作为_小也有大作为                   // Console.WriteLine(“从消息队列中取数据Over.at:” + DateTime.Now.ToString());
44小网点也有大作为_小也有大作为
45小网点也有大作为_小也有大作为                    //process the queued orders
46小网点也有大作为_小也有大作为小网点也有大作为_小也有大作为                    for (int k = 0; k < queueOrders.Count; k++小网点也有大作为_小也有大作为{

47小网点也有大作为_小也有大作为                        order.Insert((OrderInfo)queueOrders[k]);
48小网点也有大作为_小也有大作为                        processedItems++;
49小网点也有大作为_小也有大作为                        totalOrdersProcessed++;
50小网点也有大作为_小也有大作为
51小网点也有大作为_小也有大作为                    }
 
52小网点也有大作为_小也有大作为                   // Console.WriteLine(“上传数据.at:” + DateTime.Now.ToString());
53小网点也有大作为_小也有大作为
54小网点也有大作为_小也有大作为                    //batch complete or MSMQ receive timed out
55小网点也有大作为_小也有大作为                    ts.Complete();
56小网点也有大作为_小也有大作为                   // Console.WriteLine(“Over.at:” + DateTime.Now.ToString());
57小网点也有大作为_小也有大作为                }

58小网点也有大作为_小也有大作为
59小网点也有大作为_小也有大作为                Console.WriteLine((Thread Id  + Thread.CurrentThread.ManagedThreadId + ) batch finished,  + processedItems +  items, in  + elapsedTime.ToString() +  seconds.at:+DateTime.Now.ToString());
60小网点也有大作为_小也有大作为            }
                      

问题在于第2行:
TimeSpan tsTimeout 
=
 TimeSpan.FromSeconds(Convert.ToDouble(transactionTimeout 
*
 batchSize));
如果在配置文件里设置

batchSize=1,那么
tsTimeout
=
transactionTimeout

所以在24行。
if
 ((elapsedTime 
+
 queueTimeout 
+
 transactionTimeout) 
<
 tsTimeout.TotalSeconds) 
小网点也有大作为_小也有大作为,这个永远为False.除非
queueTimeout为负数

转载于:https://www.cnblogs.com/zhpeng/archive/2008/04/17/1157436.html

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/181174.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)
blank

相关推荐

  • Swift的属性,方法,下标脚本以及继承

    Swift的属性,方法,下标脚本以及继承

    2021年12月16日
  • C# Sort排序

    C# Sort排序List的Sort方法排序有三种结果1,0,-1分别表示大于,等于,小于。1.对于数值类型的List(List),直接使用Sort进行排序。ListscoreList=newList(){89,100,78,23,67};scoreList.Sort();//默认按升序排列,相当于:scoreList.Sort((x,y)=>x.CompareTo(y))scoreLis

  • macpycharm2021激活码【在线注册码/序列号/破解码】

    macpycharm2021激活码【在线注册码/序列号/破解码】,https://javaforall.cn/100143.html。详细ieda激活码不妨到全栈程序员必看教程网一起来了解一下吧!

  • global container line_ebs oracle

    global container line_ebs oraclePrometheusexporterforcustomeBPFmetrics.MotivationofthisexporteristoallowyoutowriteeBPFcodeandexportmetricsthatarenototherwiseaccessiblefromtheLinuxkernel.https://github.com/cloudflare/ebpf_exporter

  • kafka官方文档_kafka groupid

    kafka官方文档_kafka groupid介绍Kafka是一个分布式的、分区的、冗余的日志提交服务。它使用了独特的设计,提供了所有消息传递系统所具有的功能。我们先来看下几个消息传递系统的术语:Kafka维护消息类别的东西是主题(topic).

  • webpack的性能优化_webpack不是内部或外部命令

    webpack的性能优化_webpack不是内部或外部命令webpack版本过高,会出现很多问题,因此可以降低版本高度1.可以直接覆盖原版本,可以输入`cnpmiwebpack需要降低的版本-g比如我们要降低到’3.6.0’’cnpmiwebpack@3.6.0-g’2.卸载当前版本,在重新下载需要的版本卸载命令:’npmuninstallwebpack-g’如果是局部安装,也可以在文件夹中找到node-modules中webpack模块删除。安装命令:’npminstallwebpack@3.6.0-g’

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号