c# – 在for循环中启动多个线程无效

下面是我必须要做的代码

private void transferMessages()
{
    MQQueueManager sqmgr = connectToQueueManager(S_SERVER_NAME,S_QMGR_NAME,S_PORT_NUMBER,S_CHANNEL_NAME);
    MQQueueManager dqmgr = connectToQueueManager(D_SERVER_NAME,D_QMGR_NAME,D_PORT_NUMBER,D_CHANNEL_NAME);
    if (sqmgr != null && dqmgr != null)
    {
        MQQueue sq = openSourceQueueToGet(sqmgr,S_QUEUE_NAME);
        MQQueue dq = openDestQueueToPut(dqmgr,D_QUEUE_NAME);
        if (sq != null && dq != null)
        {
            setPutMessageOptions();
            setGetMessageOptions();
            processMessages(sqmgr,sq,dqmgr,dq);
        }
    }
}

我在for循环中调用上面的方法并创建如下的单独线程.

int NO_OF_THREADS = 5;
Thread[] ts = new Thread[NO_OF_THREADS];
for (int i = 0; i < NO_OF_THREADS; i++)
{ 
    ts[i] = new Thread(() => transferMessages());
    ts[i].Start();        
}

如您所见,我正在与transferMessages方法中的队列管理器建立新的连接.不确定由于某种原因,程序只与MQ建立一个连接.

连接到队列管理器的自定义方法如下.

private MQQueueManager connectToQueueManager(string MQServerName,string MQQueueManagerName,string MQPortNumber,string MQChannel)
    {
        try
        {
            mqErrorString = "";
            MQQueueManager qmgr;
            Hashtable mqProps = new Hashtable();
            mqProps.Add(MQC.HOST_NAME_PROPERTY,MQServerName);
            mqProps.Add(MQC.CHANNEL_PROPERTY,MQChannel);
            mqProps.Add(MQC.PORT_PROPERTY,Convert.ToInt32(MQPortNumber));
            mqProps.Add(MQC.TRANSPORT_PROPERTY,MQC.TRANSPORT_MQSERIES_CLIENT);
            qmgr = new MQQueueManager(MQQueueManagerName,mqProps);
            return qmgr;
        }
        catch (MQException mqex)
        {
            //catch and log MQException here
            return null;
        }
    }

有什么建议我错过了什么？