在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