限时等待某一任务完成示例

<pre name="code" class="csharp">        /// <summary>
/// 获取客户端 1.5s 超时
/// </summary>
/// <param name="index"></param>
/// <returns></returns>
private IRedisClient GetClientByTimeOut(int index, bool throwException = false)
{
if (_redisClients == null || index < 0 || index >= _redisClients.Length)
{
return null;
}

var cm = _redisClients[index];
if (cm == null)
{
return null;
}

int timeout = 1500;//超时ms
var t = System.Threading.Tasks.Task.Factory.StartNew((c) =>
{
var prcm=((PooledRedisClientManager)c);
var cc= prcm.GetClient();
return cc;
}, cm);
bool right = t.Wait(timeout);
if (right) return t.Result;

if (throwException)
{
string info = string.Format("无法获取第{0}个Redis客户端，可能该Redis实例已挂掉。", index);
throw new Exception(info);
}

//logger.Info(info);
return null;
}