implab/ImplabNet Commit - r74:c4140283575c

1

using System;

1

using System;

2

using System.Collections.Generic;

2

using System.Collections.Generic;

3

using System.Reflection;

3

using System.Reflection;

4

using System.Diagnostics;

4

using System.Diagnostics;

5

using System.Threading;

5

using System.Threading;

6

using Implab.Parallels;

6

using Implab.Parallels;

7

8

namespace Implab {

8

namespace Implab {

9

10

public delegate void ErrorHandler(Exception e);

10

public delegate void ErrorHandler(Exception e);

11

public delegate T ErrorHandler<out T>(Exception e);

11

public delegate T ErrorHandler<out T>(Exception e);

12

public delegate void ResultHandler<in T>(T result);

12

public delegate void ResultHandler<in T>(T result);

13

public delegate TNew ResultMapper<in TSrc,out TNew>(TSrc result);

13

public delegate TNew ResultMapper<in TSrc,out TNew>(TSrc result);

14

public delegate IPromise<TNew> ChainedOperation<in TSrc,TNew>(TSrc result);

14

public delegate IPromise<TNew> ChainedOperation<in TSrc,TNew>(TSrc result);

15

16

/// <summary>

16

/// <summary>

17

/// Класс для асинхронного получения результатов. Так называемое "обещание".

17

/// Класс для асинхронного получения результатов. Так называемое "обещание".

18

/// </summary>

18

/// </summary>

19

/// <typeparam name="T">Тип получаемого результата</typeparam>

19

/// <typeparam name="T">Тип получаемого результата</typeparam>

20

/// <remarks>

20

/// <remarks>

21

/// <para>Сервис при обращении к его методу дает обещаиние о выполнении операции,

21

/// <para>Сервис при обращении к его методу дает обещаиние о выполнении операции,

22

/// клиент получив такое обещание может установить ряд обратных вызово для получения

22

/// клиент получив такое обещание может установить ряд обратных вызово для получения

23

/// событий выполнения обещания, тоесть завершения операции и предоставлении результатов.</para>

23

/// событий выполнения обещания, тоесть завершения операции и предоставлении результатов.</para>

24

/// <para>

24

/// <para>

25

/// Обещение может быть как выполнено, так и выполнено с ошибкой. Для подписки на

25

/// Обещение может быть как выполнено, так и выполнено с ошибкой. Для подписки на

26

/// данные события клиент должен использовать методы <c>Then</c>.

26

/// данные события клиент должен использовать методы <c>Then</c>.

27

/// </para>

27

/// </para>

28

/// <para>

28

/// <para>

29

/// Сервис, в свою очередь, по окончанию выполнения операции (возможно с ошибкой),

29

/// Сервис, в свою очередь, по окончанию выполнения операции (возможно с ошибкой),

30

/// использует методы <c>Resolve</c> либо <c>Reject</c> для оповещения клиетна о

30

/// использует методы <c>Resolve</c> либо <c>Reject</c> для оповещения клиетна о

31

/// выполнении обещания.

31

/// выполнении обещания.

32

/// </para>

32

/// </para>

33

/// <para>

33

/// <para>

34

/// Если сервер успел выполнить обещание еще до того, как клиент на него подписался,

34

/// Если сервер успел выполнить обещание еще до того, как клиент на него подписался,

35

/// то в момент подписки клиента будут вызваны соответсвующие события в синхронном

35

/// то в момент подписки клиента будут вызваны соответсвующие события в синхронном

36

/// режиме и клиент будет оповещен в любом случае. Иначе, обработчики добавляются в

36

/// режиме и клиент будет оповещен в любом случае. Иначе, обработчики добавляются в

37

/// список в порядке подписания и в этом же порядке они будут вызваны при выполнении

37

/// список в порядке подписания и в этом же порядке они будут вызваны при выполнении

38

/// обещания.

38

/// обещания.

39

/// </para>

39

/// </para>

40

/// <para>

40

/// <para>

41

/// Обрабатывая результаты обещания можно преобразовывать результаты либо инициировать

41

/// Обрабатывая результаты обещания можно преобразовывать результаты либо инициировать

42

/// связанные асинхронные операции, которые также возвращают обещания. Для этого следует

42

/// связанные асинхронные операции, которые также возвращают обещания. Для этого следует

43

/// использовать соответствующую форму методе <c>Then</c>.

43

/// использовать соответствующую форму методе <c>Then</c>.

44

/// </para>

44

/// </para>

45

/// <para>

45

/// <para>

46

/// Также хорошим правилом является то, что <c>Resolve</c> и <c>Reject</c> должен вызывать

46

/// Также хорошим правилом является то, что <c>Resolve</c> и <c>Reject</c> должен вызывать

47

/// только инициатор обещания иначе могут возникнуть противоречия.

47

/// только инициатор обещания иначе могут возникнуть противоречия.

48

/// </para>

48

/// </para>

49

/// </remarks>

49

/// </remarks>

50

public class Promise<T> : IPromise<T> {

50

public class Promise<T> : IPromise<T> {

51

52

protected struct HandlerDescriptor {

52

protected struct HandlerDescriptor {

53

public ResultHandler<T> resultHandler;

53

public ResultHandler<T> resultHandler;

54

public ErrorHandler<T> errorHandler;

54

public ErrorHandler<T> errorHandler;

55

public Action cancellHandler;

55

public Action cancellHandler;

56

public Promise<T> medium;

56

public Promise<T> medium;

57

58

public void Resolve(T result) {

58

public void Resolve(T result) {

59

if (resultHandler != null) {

59

if (resultHandler != null) {

60

try {

60

try {

61

resultHandler(result);

61

resultHandler(result);

62

} catch (Exception e) {

62

} catch (Exception e) {

63

Reject(e);

63

Reject(e);

64

return;

64

return;

65

}

65

}

66

}

66

}

67

if (medium != null)

67

if (medium != null)

68

medium.Resolve(result);

68

medium.Resolve(result);

69

}

69

}

70

71

public void Reject(Exception err) {

71

public void Reject(Exception err) {

72

if (errorHandler != null) {

72

if (errorHandler != null) {

73

try {

73

try {

74

var res = errorHandler(err);

74

var res = errorHandler(err);

75

if (medium != null)

75

if (medium != null)

76

medium.Resolve(res);

76

medium.Resolve(res);

77

} catch (TransientPromiseException err2) {

77

} catch (TransientPromiseException err2) {

78

if (medium != null)

78

if (medium != null)

79

medium.Reject(err2.InnerException);

79

medium.Reject(err2.InnerException);

80

} catch (Exception err2) {

80

} catch (Exception err2) {

81

if (medium != null)

81

if (medium != null)

82

medium.Reject(err2);

82

medium.Reject(err2);

83

}

83

}

84

} else if (medium != null)

84

} else if (medium != null)

85

medium.Reject(err);

85

medium.Reject(err);

86

}

86

}

87

88

public void Cancel() {

88

public void Cancel() {

89

if (cancellHandler != null) {

89

if (cancellHandler != null) {

90

try {

90

try {

91

cancellHandler();

91

cancellHandler();

92

} catch (Exception err) {

92

} catch (Exception err) {

93

Reject(err);

93

Reject(err);

94

return;

94

return;

95

}

95

}

96

}

96

}

97

if (medium != null)

97

if (medium != null)

98

medium.Cancel();

98

medium.Cancel();

99

}

99

}

100

}

100

}

101

102

const int UNRESOLVED_SATE = 0;

102

const int UNRESOLVED_SATE = 0;

103

const int TRANSITIONAL_STATE = 1;

103

const int TRANSITIONAL_STATE = 1;

104

const int SUCCEEDED_STATE = 2;

104

const int SUCCEEDED_STATE = 2;

105

const int REJECTED_STATE = 3;

105

const int REJECTED_STATE = 3;

106

const int CANCELLED_STATE = 4;

106

const int CANCELLED_STATE = 4;

107

108

readonly bool m_cancellable;

108

readonly bool m_cancellable;

109

110

int m_childrenCount = 0;

110

int m_childrenCount = 0;

111

int m_state;

111

int m_state;

112

T m_result;

112

T m_result;

113

Exception m_error;

113

Exception m_error;

114

115

readonly MTQueue<HandlerDescriptor> m_handlers = new MTQueue<HandlerDescriptor>();

115

readonly MTQueue<HandlerDescriptor> m_handlers = new MTQueue<HandlerDescriptor>();

116

117

public Promise() {

117

public Promise() {

118

m_cancellable = true;

118

m_cancellable = true;

119

}

119

}

120

121

public Promise(IPromise parent, bool cancellable) {

121

public Promise(IPromise parent, bool cancellable) {

122

m_cancellable = cancellable;

122

m_cancellable = cancellable;

123

if (parent != null)

123

if (parent != null)

124

Cancelled(() => {

124

Cancelled(() => {

125

if (parent.IsExclusive)

125

if (parent.IsExclusive)

126

parent.Cancel();

126

parent.Cancel();

127

});

127

});

128

}

128

}

129

130

bool BeginTransit() {

130

bool BeginTransit() {

131

return UNRESOLVED_SATE == Interlocked.CompareExchange(ref m_state, TRANSITIONAL_STATE, UNRESOLVED_SATE);

131

return UNRESOLVED_SATE == Interlocked.CompareExchange(ref m_state, TRANSITIONAL_STATE, UNRESOLVED_SATE);

132

}

132

}

133

134

void CompleteTransit(int state) {

134

void CompleteTransit(int state) {

135

if (TRANSITIONAL_STATE != Interlocked.CompareExchange(ref m_state, state, TRANSITIONAL_STATE))

135

if (TRANSITIONAL_STATE != Interlocked.CompareExchange(ref m_state, state, TRANSITIONAL_STATE))

136

throw new InvalidOperationException("Can't complete transition when the object isn't in the transitional state");

136

throw new InvalidOperationException("Can't complete transition when the object isn't in the transitional state");

137

}

137

}

138

139

void WaitTransition() {

139

void WaitTransition() {

140

while (m_state == TRANSITIONAL_STATE) {

140

while (m_state == TRANSITIONAL_STATE) {

141

/* noop */

141

/* noop */

142

}

142

}

143

}

143

}

144

145

public bool IsResolved {

145

public bool IsResolved {

146

get {

146

get {

147

return m_state > 1;

147

return m_state > 1;

148

}

148

}

149

}

149

}

150

151

public bool IsCancelled {

151

public bool IsCancelled {

152

get {

152

get {

153

return m_state == CANCELLED_STATE;

153

return m_state == CANCELLED_STATE;

154

}

154

}

155

}

155

}

156

157

public Type PromiseType {

157

public Type PromiseType {

158

get { return typeof(T); }

158

get { return typeof(T); }

159

}

159

}

160

161

/// <summary>

161

/// <summary>

162

/// Выполняет обещание, сообщая об успешном выполнении.

162

/// Выполняет обещание, сообщая об успешном выполнении.

163

/// </summary>

163

/// </summary>

164

/// <param name="result">Результат выполнения.</param>

164

/// <param name="result">Результат выполнения.</param>

165

/// <exception cref="InvalidOperationException">Данное обещание уже выполнено</exception>

165

/// <exception cref="InvalidOperationException">Данное обещание уже выполнено</exception>

166

public void Resolve(T result) {

166

public void Resolve(T result) {

167

if (BeginTransit()) {

167

if (BeginTransit()) {

168

m_result = result;

168

m_result = result;

169

CompleteTransit(SUCCEEDED_STATE);

169

CompleteTransit(SUCCEEDED_STATE);

170

OnStateChanged();

170

OnStateChanged();

171

} else {

171

} else {

172

WaitTransition();

172

WaitTransition();

173

if (m_state != CANCELLED_STATE)

173

if (m_state != CANCELLED_STATE)

174

throw new InvalidOperationException("The promise is already resolved");

174

throw new InvalidOperationException("The promise is already resolved");

175

}

175

}

176

}

176

}

177

178

/// <summary>

178

/// <summary>

179

/// Выполняет обещание, сообщая об успешном выполнении. Результатом выполнения будет пустое значения.

179

/// Выполняет обещание, сообщая об успешном выполнении. Результатом выполнения будет пустое значения.

180

/// </summary>

180

/// </summary>

181

/// <remarks>

181

/// <remarks>

182

/// Данный вариант удобен в случаях, когда интересен факт выполнения операции, нежели полученное значение.

182

/// Данный вариант удобен в случаях, когда интересен факт выполнения операции, нежели полученное значение.

183

/// </remarks>

183

/// </remarks>

184

public void Resolve() {

184

public void Resolve() {

185

Resolve(default(T));

185

Resolve(default(T));

186

}

186

}

187

188

/// <summary>

188

/// <summary>

189

/// Выполняет обещание, сообщая об ошибке

189

/// Выполняет обещание, сообщая об ошибке

190

/// </summary>

190

/// </summary>

191

/// <remarks>

191

/// <remarks>

192

/// Поскольку обещание должно работать в многопточной среде, при его выполнении сразу несколько потоков

192

/// Поскольку обещание должно работать в многопточной среде, при его выполнении сразу несколько потоков

193

/// могу вернуть ошибку, при этом только первая будет использована в качестве результата, остальные

193

/// могу вернуть ошибку, при этом только первая будет использована в качестве результата, остальные

194

/// будут проигнорированы.

194

/// будут проигнорированы.

195

/// </remarks>

195

/// </remarks>

196

/// <param name="error">Исключение возникшее при выполнении операции</param>

196

/// <param name="error">Исключение возникшее при выполнении операции</param>

197

/// <exception cref="InvalidOperationException">Данное обещание уже выполнено</exception>

197

/// <exception cref="InvalidOperationException">Данное обещание уже выполнено</exception>

198

public void Reject(Exception error) {

198

public void Reject(Exception error) {

199

if (BeginTransit()) {

199

if (BeginTransit()) {

200

m_error = error;

200

m_error = error;

201

CompleteTransit(REJECTED_STATE);

201

CompleteTransit(REJECTED_STATE);

202

OnStateChanged();

202

OnStateChanged();

203

} else {

203

} else {

204

WaitTransition();

204

WaitTransition();

205

if (m_state == SUCCEEDED_STATE)

205

if (m_state == SUCCEEDED_STATE)

206

throw new InvalidOperationException("The promise is already resolved");

206

throw new InvalidOperationException("The promise is already resolved");

207

}

207

}

208

}

208

}

209

210

/// <summary>

210

/// <summary>

211

/// Отменяет операцию, если это возможно.

211

/// Отменяет операцию, если это возможно.

212

/// </summary>

212

/// </summary>

213

/// <returns><c>true</c> Операция была отменена, обработчики не будут вызваны.<c>false</c> отмена не возможна, поскольку обещание уже выполнено и обработчики отработали.</returns>

213

/// <returns><c>true</c> Операция была отменена, обработчики не будут вызваны.<c>false</c> отмена не возможна, поскольку обещание уже выполнено и обработчики отработали.</returns>

214

public bool Cancel() {

214

public bool Cancel() {

215

if (m_cancellable && BeginTransit()) {

215

if (m_cancellable && BeginTransit()) {

216

CompleteTransit(CANCELLED_STATE);

216

CompleteTransit(CANCELLED_STATE);

217

OnStateChanged();

217

OnStateChanged();

218

return true;

218

return true;

219

}

219

}

220

return false;

220

return false;

221

}

221

}

222

223

// сделано для возвращаемого типа void

223

// сделано для возвращаемого типа void

224

protected void InternalCancel() {

224

protected void InternalCancel() {

225

Cancel();

225

Cancel();

226

}

226

}

227

228

/// <summary>

228

/// <summary>

229

/// Adds new handlers to this promise.

229

/// Adds new handlers to this promise.

230

/// </summary>

230

/// </summary>

231

/// <param name="success">The handler of the successfully completed operation.

231

/// <param name="success">The handler of the successfully completed operation.

232

/// This handler will recieve an operation result as a parameter.</param>

232

/// This handler will recieve an operation result as a parameter.</param>

233

/// <param name="error">Handles an exception that may occur during the operation and returns the value which will be used as the result of the operation.</param>

233

/// <param name="error">Handles an exception that may occur during the operation and returns the value which will be used as the result of the operation.</param>

234

/// <returns>The new promise chained to this one.</returns>

234

/// <returns>The new promise chained to this one.</returns>

235

public IPromise<T> Then(ResultHandler<T> success, ErrorHandler<T> error) {

235

public IPromise<T> Then(ResultHandler<T> success, ErrorHandler<T> error) {

236

if (success == null && error == null)

236

if (success == null && error == null)

237

return this;

237

return this;

238

239

var medium = new Promise<T>(this, true);

239

var medium = new Promise<T>(this, true);

240

241

AddHandler(success, error, null, medium);

241

AddHandler(success, error, null, medium);

242

243

return medium;

243

return medium;

244

}

244

}

245

246

public IPromise Then(Action success, ErrorHandler error) {

246

public IPromise Then(Action success, ErrorHandler error) {

247

return Then(

247

return Then(

248

x => success(),

248

x => success(),

249

e => {

249

e => {

250

error(e);

250

error(e);

251

return default(T);

251

return default(T);

252

}

252

}

253

);

253

);

254

}

254

}

255

256

public IPromise Then(Action success) {

256

public IPromise Then(Action success) {

257

return Then(x => success());

257

return Then(x => success());

258

}

258

}

259

260

261

public IPromise<T> Then(ResultHandler<T> success) {

261

public IPromise<T> Then(ResultHandler<T> success) {

262

if (success == null)

262

if (success == null)

263

return this;

263

return this;

264

265

var medium = new Promise<T>(this, true);

265

var medium = new Promise<T>(this, true);

266

267

AddHandler(success, null, null, medium);

267

AddHandler(success, null, null, medium);

268

269

return medium;

269

return medium;

270

}

270

}

271

272

public IPromise Error(ErrorHandler error) {

272

public IPromise Error(ErrorHandler error) {

273

if (error == null)

273

if (error == null)

274

return this;

274

return this;

275

276

var medium = new Promise<T>(this, true);

276

var medium = new Promise<T>(this, true);

277

278

AddHandler(

278

AddHandler(

279

null,

279

null,

280

e => {

280

e => {

281

error(e);

281

error(e);

282

return default(T);

282

return default(T);

283

},

283

},

284

null,

284

null,

285

medium

285

medium

286

);

286

);

287

288

return medium;

288

return medium;

289

}

289

}

290

291

/// <summary>

291

/// <summary>

292

/// Handles error and allows to keep the promise.

292

/// Handles error and allows to keep the promise.

293

/// </summary>

293

/// </summary>

294

/// <remarks>

294

/// <remarks>

295

/// If the specified handler throws an exception, this exception will be used to reject the promise.

295

/// If the specified handler throws an exception, this exception will be used to reject the promise.

296

/// </remarks>

296

/// </remarks>

297

/// <param name="handler">The error handler which returns the result of the promise.</param>

297

/// <param name="handler">The error handler which returns the result of the promise.</param>

298

/// <returns>New promise.</returns>

298

/// <returns>New promise.</returns>

299

public IPromise<T> Error(ErrorHandler<T> handler) {

299

public IPromise<T> Error(ErrorHandler<T> handler) {

300

if (handler == null)

300

if (handler == null)

301

return this;

301

return this;

302

303

var medium = new Promise<T>(this, true);

303

var medium = new Promise<T>(this, true);

304

305

AddHandler(null, handler, null, medium);

305

AddHandler(null, handler, null, medium);

306

307

return medium;

307

return medium;

308

}

308

}

309

310

public IPromise<T> Anyway(Action handler) {

310

public IPromise<T> Anyway(Action handler) {

311

if (handler == null)

311

if (handler == null)

312

return this;

312

return this;

313

314

var medium = new Promise<T>(this, true);

314

var medium = new Promise<T>(this, true);

315

316

AddHandler(

316

AddHandler(

317

x => handler(),

317

x => handler(),

318

e => {

318

e => {

319

handler();

319

handler();

320

throw new TransientPromiseException(e);

320

throw new TransientPromiseException(e);

321

},

321

},

322

null,

322

null,

323

medium

323

medium

324

);

324

);

325

326

return medium;

326

return medium;

327

}

327

}

328

329

/// <summary>

329

/// <summary>

330

/// Позволяет преобразовать результат выполения операции к новому типу.

330

/// Позволяет преобразовать результат выполения операции к новому типу.

331

/// </summary>

331

/// </summary>

332

/// <typeparam name="TNew">Новый тип результата.</typeparam>

332

/// <typeparam name="TNew">Новый тип результата.</typeparam>

333

/// <param name="mapper">Преобразование результата к новому типу.</param>

333

/// <param name="mapper">Преобразование результата к новому типу.</param>

334

/// <param name="error">Обработчик ошибки. Данный обработчик получит

334

/// <param name="error">Обработчик ошибки. Данный обработчик получит

335

/// исключение возникшее при выполнении операции.</param>

335

/// исключение возникшее при выполнении операции.</param>

336

/// <returns>Новое обещание, которое будет выполнено при выполнении исходного обещания.</returns>

336

/// <returns>Новое обещание, которое будет выполнено при выполнении исходного обещания.</returns>

337

public IPromise<TNew> Map<TNew>(ResultMapper<T, TNew> mapper, ErrorHandler<T> error) {

337

public IPromise<TNew> Map<TNew>(ResultMapper<T, TNew> mapper, ErrorHandler<T> error) {

338

if (mapper == null)

338

if (mapper == null)

339

throw new ArgumentNullException("mapper");

339

throw new ArgumentNullException("mapper");

340

341

// создаем прицепленное обещание

341

// создаем прицепленное обещание

342

var chained = new Promise<TNew>(this, true);

342

var chained = new Promise<TNew>(this, true);

343

344

ResultHandler<T> resultHandler = result => chained.Resolve(mapper(result));

344

ResultHandler<T> resultHandler = result => chained.Resolve(mapper(result));

345

ErrorHandler<T> errorHandler;

345

ErrorHandler<T> errorHandler;

346

if (error != null)

346

if (error != null)

347

errorHandler = e => {

347

errorHandler = e => {

348

try {

348

try {

349

return error(e);

349

return error(e);

350

} catch (Exception e2) {

350

} catch (Exception e2) {

351

// в случае ошибки нужно передать исключение дальше по цепочке

351

// в случае ошибки нужно передать исключение дальше по цепочке

352

chained.Reject(e2);

352

chained.Reject(e2);

353

}

353

}

354

return default(T);

354

return default(T);

355

};

355

};

356

else

356

else

357

errorHandler = e => {

357

errorHandler = e => {

358

chained.Reject(e);

358

chained.Reject(e);

359

return default(T);

359

return default(T);

360

};

360

};

361

362

363

AddHandler(

363

AddHandler(

364

resultHandler,

364

resultHandler,

365

errorHandler,

365

errorHandler,

366

chained.InternalCancel,

366

chained.InternalCancel,

367

null

367

null

368

);

368

);

369

370

return chained;

370

return chained;

371

}

371

}

372

373

public IPromise<TNew> Map<TNew>(ResultMapper<T, TNew> mapper) {

373

public IPromise<TNew> Map<TNew>(ResultMapper<T, TNew> mapper) {

374

return Map(mapper, null);

374

return Map(mapper, null);

375

}

375

}

376

377

/// <summary>

377

/// <summary>

378

/// Сцепляет несколько аснхронных операций. Указанная асинхронная операция будет вызвана после

378

/// Сцепляет несколько аснхронных операций. Указанная асинхронная операция будет вызвана после

379

/// выполнения текущей, а результат текущей операции может быть использован для инициализации

379

/// выполнения текущей, а результат текущей операции может быть использован для инициализации

380

/// новой операции.

380

/// новой операции.

381

/// </summary>

381

/// </summary>

382

/// <typeparam name="TNew">Тип результата указанной асинхронной операции.</typeparam>

382

/// <typeparam name="TNew">Тип результата указанной асинхронной операции.</typeparam>

383

/// <param name="chained">Асинхронная операция, которая должна будет начаться после выполнения текущей.</param>

383

/// <param name="chained">Асинхронная операция, которая должна будет начаться после выполнения текущей.</param>

384

/// <param name="error">Обработчик ошибки. Данный обработчик получит

384

/// <param name="error">Обработчик ошибки. Данный обработчик получит

385

/// исключение возникшее при выполнении текуещй операции.</param>

385

/// исключение возникшее при выполнении текуещй операции.</param>

386

/// <returns>Новое обещание, которое будет выполнено по окончанию указанной аснхронной операции.</returns>

386

/// <returns>Новое обещание, которое будет выполнено по окончанию указанной аснхронной операции.</returns>

387

public IPromise<TNew> Chain<TNew>(ChainedOperation<T, TNew> chained, ErrorHandler<T> error) {

387

public IPromise<TNew> Chain<TNew>(ChainedOperation<T, TNew> chained, ErrorHandler<T> error) {

388

389

// проблема в том, что на момент связывания еще не начата асинхронная операция, поэтому нужно

389

// проблема в том, что на момент связывания еще не начата асинхронная операция, поэтому нужно

390

// создать посредника, к которому будут подвызяваться следующие обработчики.

390

// создать посредника, к которому будут подвызяваться следующие обработчики.

391

// когда будет выполнена реальная асинхронная операция, она обратиться к посреднику, чтобы

391

// когда будет выполнена реальная асинхронная операция, она обратиться к посреднику, чтобы

392

// передать через него результаты работы.

392

// передать через него результаты работы.

393

var medium = new Promise<TNew>(this, true);

393

var medium = new Promise<TNew>(this, true);

394

395

ResultHandler<T> resultHandler = delegate(T result) {

395

ResultHandler<T> resultHandler = delegate(T result) {

396

if (medium.IsCancelled)

396

if (medium.IsCancelled)

397

return;

397

return;

398

399

var promise = chained(result);

399

var promise = chained(result);

400

401

promise.Then(

401

promise.Then(

402

medium.Resolve,

402

medium.Resolve,

403

err => {

403

err => {

404

medium.Reject(err);

404

medium.Reject(err);

405

throw new TransientPromiseException(err);

405

throw new TransientPromiseException(err);

406

}

406

}

407

);

407

);

408

409

// notify chained operation that it's not needed anymore

409

// notify chained operation that it's not needed anymore

410

// порядок вызова Then, Cancelled важен, поскольку от этого

410

// порядок вызова Then, Cancelled важен, поскольку от этого

411

// зависит IsExclusive

411

// зависит IsExclusive

412

medium.Cancelled(() => {

412

medium.Cancelled(() => {

413

if (promise.IsExclusive)

413

if (promise.IsExclusive)

414

promise.Cancel();

414

promise.Cancel();

415

});

415

});

416

417

// внешняя отмена связанной операции рассматривается как ошибка

417

// внешняя отмена связанной операции рассматривается как ошибка

418

promise.Cancelled(() => medium.Reject(new OperationCanceledException()));

418

promise.Cancelled(() => medium.Reject(new OperationCanceledException()));

419

};

419

};

420

421

ErrorHandler<T> errorHandler = delegate(Exception e) {

421

ErrorHandler<T> errorHandler = delegate(Exception e) {

422

if (error != null) {

422

if (error != null) {

423

try {

423

try {

424

return error(e);

424

return error(e);

425

} catch (Exception e2) {

425

} catch (Exception e2) {

426

medium.Reject(e2);

426

medium.Reject(e2);

427

return default(T);

427

return default(T);

428

}

428

}

429

}

429

}

430

// в случае ошибки нужно передать исключение дальше по цепочке

430

// в случае ошибки нужно передать исключение дальше по цепочке

431

medium.Reject(e);

431

medium.Reject(e);

432

return default(T);

432

return default(T);

433

};

433

};

434

435

AddHandler(

435

AddHandler(

436

resultHandler,

436

resultHandler,

437

errorHandler,

437

errorHandler,

438

medium.InternalCancel,

438

medium.InternalCancel,

439

null

439

null

440

);

440

);

441

442

return medium;

442

return medium;

443

}

443

}

444

445

public IPromise<TNew> Chain<TNew>(ChainedOperation<T, TNew> chained) {

445

public IPromise<TNew> Chain<TNew>(ChainedOperation<T, TNew> chained) {

446

return Chain(chained, null);

446

return Chain(chained, null);

447

}

447

}

448

449

public IPromise<T> Cancelled(Action handler) {

449

public IPromise<T> Cancelled(Action handler) {

450

AddHandler(null, null, handler, null);

450

var medium = new Promise<T>(this, true);

451

return this;

451

AddHandler(null, null, handler, medium);

452

return medium;

452

}

453

}

453

454

/// <summary>

455

/// <summary>

455

/// Adds the specified handler for all cases (success, error, cancel)

456

/// Adds the specified handler for all cases (success, error, cancel)

456

/// </summary>

457

/// </summary>

457

/// <param name="handler">The handler that will be called anyway</param>

458

/// <param name="handler">The handler that will be called anyway</param>

458

/// <returns>self</returns>

459

/// <returns>self</returns>

459

public IPromise<T> Finally(Action handler) {

460

public IPromise<T> Finally(Action handler) {

460

if (handler == null)

461

if (handler == null)

461

throw new ArgumentNullException("handler");

462

throw new ArgumentNullException("handler");

462

AddHandler(

463

AddHandler(

463

x => handler(),

464

x => handler(),

464

e => {

465

e => {

465

handler();

466

handler();

466

throw new TransientPromiseException(e);

467

throw new TransientPromiseException(e);

467

},

468

},

468

handler,

469

handler,

469

null

470

null

470

);

471

);

471

return this;

472

return this;

472

}

473

}

473

474

/// <summary>

475

/// <summary>

475

/// Преобразует результат обещания к нужному типу

476

/// Преобразует результат обещания к нужному типу

476

/// </summary>

477

/// </summary>

477

/// <typeparam name="T2"></typeparam>

478

/// <typeparam name="T2"></typeparam>

478

/// <returns></returns>

479

/// <returns></returns>

479

public IPromise<T2> Cast<T2>() {

480

public IPromise<T2> Cast<T2>() {

480

return Map(x => (T2)(object)x, null);

481

return Map(x => (T2)(object)x, null);

481

}

482

}

482

483

/// <summary>

484

/// <summary>

484

/// Дожидается отложенного обещания и в случае успеха, возвращает

485

/// Дожидается отложенного обещания и в случае успеха, возвращает

485

/// его, результат, в противном случае бросает исключение.

486

/// его, результат, в противном случае бросает исключение.

486

/// </summary>

487

/// </summary>

487

/// <remarks>

488

/// <remarks>

488

/// <para>

489

/// <para>

489

/// Если ожидание обещания было прервано по таймауту, это не значит,

490

/// Если ожидание обещания было прервано по таймауту, это не значит,

490

/// что обещание было отменено или что-то в этом роде, это только

491

/// что обещание было отменено или что-то в этом роде, это только

491

/// означает, что мы его не дождались, однако все зарегистрированные

492

/// означает, что мы его не дождались, однако все зарегистрированные

492

/// обработчики, как были так остались и они будут вызваны, когда

493

/// обработчики, как были так остались и они будут вызваны, когда

493

/// обещание будет выполнено.

494

/// обещание будет выполнено.

494

/// </para>

495

/// </para>

495

/// <para>

496

/// <para>

496

/// Такое поведение вполне оправдано поскольку таймаут может истечь

497

/// Такое поведение вполне оправдано поскольку таймаут может истечь

497

/// в тот момент, когда началась обработка цепочки обработчиков, и

498

/// в тот момент, когда началась обработка цепочки обработчиков, и

498

/// к тому же текущее обещание может стоять в цепочке обещаний и его

499

/// к тому же текущее обещание может стоять в цепочке обещаний и его

499

/// отклонение может привести к непрогнозируемому результату.

500

/// отклонение может привести к непрогнозируемому результату.

500

/// </para>

501

/// </para>

501

/// </remarks>

502

/// </remarks>

502

/// <param name="timeout">Время ожидания</param>

503

/// <param name="timeout">Время ожидания</param>

503

/// <returns>Результат выполнения обещания</returns>

504

/// <returns>Результат выполнения обещания</returns>

504

public T Join(int timeout) {

505

public T Join(int timeout) {

505

var evt = new ManualResetEvent(false);

506

var evt = new ManualResetEvent(false);

506

Anyway(() => evt.Set());

507

Anyway(() => evt.Set());

507

Cancelled(() => evt.Set());

508

Cancelled(() => evt.Set());

508

509

if (!evt.WaitOne(timeout, true))

510

if (!evt.WaitOne(timeout, true))

510

throw new TimeoutException();

511

throw new TimeoutException();

511

512

switch (m_state) {

513

switch (m_state) {

513

case SUCCEEDED_STATE:

514

case SUCCEEDED_STATE:

514

return m_result;

515

return m_result;

515

case CANCELLED_STATE:

516

case CANCELLED_STATE:

516

throw new OperationCanceledException();

517

throw new OperationCanceledException();

517

case REJECTED_STATE:

518

case REJECTED_STATE:

518

throw new TargetInvocationException(m_error);

519

throw new TargetInvocationException(m_error);

519

default:

520

default:

520

throw new ApplicationException(String.Format("Invalid promise state {0}", m_state));

521

throw new ApplicationException(String.Format("Invalid promise state {0}", m_state));

521

}

522

}

522

}

523

}

523

524

public T Join() {

525

public T Join() {

525

return Join(Timeout.Infinite);

526

return Join(Timeout.Infinite);

526

}

527

}

527

528

void AddHandler(ResultHandler<T> success, ErrorHandler<T> error, Action cancel, Promise<T> medium) {

529

void AddHandler(ResultHandler<T> success, ErrorHandler<T> error, Action cancel, Promise<T> medium) {

529

if (success != null || error != null)

530

if (success != null || error != null)

530

Interlocked.Increment(ref m_childrenCount);

531

Interlocked.Increment(ref m_childrenCount);

531

532

var handler = new HandlerDescriptor {

533

var handler = new HandlerDescriptor {

533

resultHandler = success,

534

resultHandler = success,

534

errorHandler = error,

535

errorHandler = error,

535

cancellHandler = cancel,

536

cancellHandler = cancel,

536

medium = medium

537

medium = medium

537

};

538

};

538

539

bool queued;

540

bool queued;

540

541

if (!IsResolved) {

542

if (!IsResolved) {

542

m_handlers.Enqueue(handler);

543

m_handlers.Enqueue(handler);

543

queued = true;

544

queued = true;

544

} else {

545

} else {

545

// the promise is in resolved state, just invoke the handled with minimum overhead

546

// the promise is in resolved state, just invoke the handled with minimum overhead

546

queued = false;

547

queued = false;

547

InvokeHandler(handler);

548

InvokeHandler(handler);

548

}

549

}

549

550

if (queued && IsResolved && m_handlers.TryDequeue(out handler))

551

if (queued && IsResolved && m_handlers.TryDequeue(out handler))

551

// if the promise have been resolved while we was adding handler to the queue

552

// if the promise have been resolved while we was adding handler to the queue

552

// we can't guarantee that someone is still processing it

553

// we can't guarantee that someone is still processing it

553

// therefore we will fetch a handler from the queue and execute it

554

// therefore we will fetch a handler from the queue and execute it

554

// note that fetched handler may be not the one that we have added

555

// note that fetched handler may be not the one that we have added

555

// even we can fetch no handlers at all :)

556

// even we can fetch no handlers at all :)

556

InvokeHandler(handler);

557

InvokeHandler(handler);

557

}

558

}

558

559

protected virtual void InvokeHandler(HandlerDescriptor handler) {

560

protected virtual void InvokeHandler(HandlerDescriptor handler) {

560

switch (m_state) {

561

switch (m_state) {

561

case SUCCEEDED_STATE:

562

case SUCCEEDED_STATE:

562

handler.Resolve(m_result);

563

handler.Resolve(m_result);

563

break;

564

break;

564

case REJECTED_STATE:

565

case REJECTED_STATE:

565

handler.Reject(m_error);

566

handler.Reject(m_error);

566

break;

567

break;

567

case CANCELLED_STATE:

568

case CANCELLED_STATE:

568

handler.Cancel();

569

handler.Cancel();

569

break;

570

break;

570

default:

571

default:

571

// do nothing

572

// do nothing

572

return;

573

return;

573

}

574

}

574

}

575

}

575

576

void OnStateChanged() {

577

void OnStateChanged() {

577

HandlerDescriptor handler;

578

HandlerDescriptor handler;

578

while (m_handlers.TryDequeue(out handler))

579

while (m_handlers.TryDequeue(out handler))

579

InvokeHandler(handler);

580

InvokeHandler(handler);

580

}

581

}

581

582

public bool IsExclusive {

583

public bool IsExclusive {

583

get {

584

get {

584

return m_childrenCount <= 1;

585

return m_childrenCount <= 1;

585

}

586

}

586

}

587

}

587

588

/// <summary>

589

/// <summary>

589

/// Объединяет несколько обещаний в одно, результатом которого является массив результатов других обещаний.

590

/// Объединяет несколько обещаний в одно, результатом которого является массив результатов других обещаний.

590

/// Если хотябы одно из переданных обещаний не будет выполнено, то новое обещение тоже не будет выполнено.

591

/// Если хотябы одно из переданных обещаний не будет выполнено, то новое обещение тоже не будет выполнено.

591

/// При отмене нового обещания, переданные обещания также будут отменены, если никто больше на них не подписан.

592

/// При отмене нового обещания, переданные обещания также будут отменены, если никто больше на них не подписан.

592

/// </summary>

593

/// </summary>

593

/// <param name="promises">Список обещаний. Если список пустой, то результирующее обещание возвращается уже выполненным.</param>

594

/// <param name="promises">Список обещаний. Если список пустой, то результирующее обещание возвращается уже выполненным.</param>

594

/// <returns>Обещание объединяющее в себе результат переданных обещаний.</returns>

595

/// <returns>Обещание объединяющее в себе результат переданных обещаний.</returns>

595

/// <exception cref="ArgumentNullException"><paramref name="promises"/> не может быть null</exception>

596

/// <exception cref="ArgumentNullException"><paramref name="promises"/> не может быть null</exception>

596

public static IPromise<T[]> CreateComposite(IList<IPromise<T>> promises) {

597

public static IPromise<T[]> CreateComposite(IList<IPromise<T>> promises) {

597

if (promises == null)

598

if (promises == null)

598

throw new ArgumentNullException();

599

throw new ArgumentNullException();

599

600

// создаем аккумулятор для результатов и результирующее обещание

601

// создаем аккумулятор для результатов и результирующее обещание

601

var result = new T[promises.Count];

602

var result = new T[promises.Count];

602

var promise = new Promise<T[]>();

603

var promise = new Promise<T[]>();

603

604

// special case

605

// special case

605

if (promises.Count == 0) {

606

if (promises.Count == 0) {

606

promise.Resolve(result);

607

promise.Resolve(result);

607

return promise;

608

return promise;

608

}

609

}

609

610

int pending = promises.Count;

611

int pending = promises.Count;

611

612

for (int i = 0; i < promises.Count; i++) {

613

for (int i = 0; i < promises.Count; i++) {

613

var dest = i;

614

var dest = i;

614

615

if (promises[i] != null) {

616

if (promises[i] != null) {

616

promises[i].Then(

617

promises[i].Then(

617

x => {

618

x => {

618

result[dest] = x;

619

result[dest] = x;

619

if (Interlocked.Decrement(ref pending) == 0)

620

if (Interlocked.Decrement(ref pending) == 0)

620

promise.Resolve(result);

621

promise.Resolve(result);

621

},

622

},

622

e => {

623

e => {

623

promise.Reject(e);

624

promise.Reject(e);

624

return default(T);

625

return default(T);

625

}

626

}

626

);

627

);

627

} else {

628

} else {

628

if (Interlocked.Decrement(ref pending) == 0)

629

if (Interlocked.Decrement(ref pending) == 0)

629

promise.Resolve(result);

630

promise.Resolve(result);

630

}

631

}

631

}

632

}

632

633

promise.Cancelled(

634

promise.Cancelled(

634

() => {

635

() => {

635

foreach (var d in promises)

636

foreach (var d in promises)

636

if (d != null && d.IsExclusive)

637

if (d != null && d.IsExclusive)

637

d.Cancel();

638

d.Cancel();

638

}

639

}

639

);

640

);

640

641

return promise;

642

return promise;

642

}

643

}

643

644

/// <summary>

645

/// <summary>

645

/// Объединяет несколько обещаний в одно. Результирующее обещание будет выполнено при

646

/// Объединяет несколько обещаний в одно. Результирующее обещание будет выполнено при

646

/// выполнении всех указанных обещаний. При этом возвращаемые значения первичных обещаний

647

/// выполнении всех указанных обещаний. При этом возвращаемые значения первичных обещаний

647

/// игнорируются.

648

/// игнорируются.

648

/// </summary>

649

/// </summary>

649

/// <param name="promises">Коллекция первичных обещаний, которые будут объеденены в одно.</param>

650

/// <param name="promises">Коллекция первичных обещаний, которые будут объеденены в одно.</param>

650

/// <returns>Новое обещание, объединяющее в себе переданные.</returns>

651

/// <returns>Новое обещание, объединяющее в себе переданные.</returns>

651

/// <remarks>

652

/// <remarks>

652

/// Если в коллекции встречаюься <c>null</c>, то они воспринимаются как выполненные обещания.

653

/// Если в коллекции встречаюься <c>null</c>, то они воспринимаются как выполненные обещания.

653

/// </remarks>

654

/// </remarks>

654

public static IPromise CreateComposite(ICollection<IPromise> promises) {

655

public static IPromise CreateComposite(ICollection<IPromise> promises) {

655

if (promises == null)

656

if (promises == null)

656

throw new ArgumentNullException();

657

throw new ArgumentNullException();

657

if (promises.Count == 0)

658

if (promises.Count == 0)

658

return Promise<object>.ResultToPromise(null);

659

return Promise<object>.ResultToPromise(null);

659

660

int countdown = promises.Count;

661

int countdown = promises.Count;

661

662

var result = new Promise<object>();

663

var result = new Promise<object>();

663

664

foreach (var d in promises) {

665

foreach (var d in promises) {

665

if (d == null) {

666

if (d == null) {

666

if (Interlocked.Decrement(ref countdown) == 0)

667

if (Interlocked.Decrement(ref countdown) == 0)

667

result.Resolve(null);

668

result.Resolve(null);

668

} else {

669

} else {

669

d.Then(() => {

670

d.Then(() => {

670

if (Interlocked.Decrement(ref countdown) == 0)

671

if (Interlocked.Decrement(ref countdown) == 0)

671

result.Resolve(null);

672

result.Resolve(null);

672

});

673

});

673

}

674

}

674

}

675

}

675

676

result.Cancelled(() => {

677

result.Cancelled(() => {

677

foreach (var d in promises)

678

foreach (var d in promises)

678

if (d != null && d.IsExclusive)

679

if (d != null && d.IsExclusive)

679

d.Cancel();

680

d.Cancel();

680

});

681

});

681

682

return result;

683

return result;

683

}

684

}

684

685

public static Promise<T> ResultToPromise(T result) {

686

public static Promise<T> ResultToPromise(T result) {

686

var p = new Promise<T>();

687

var p = new Promise<T>();

687

p.Resolve(result);

688

p.Resolve(result);

688

return p;

689

return p;

689

}

690

}

690

691

public static Promise<T> ExceptionToPromise(Exception error) {

692

public static Promise<T> ExceptionToPromise(Exception error) {

692

if (error == null)

693

if (error == null)

693

throw new ArgumentNullException();

694

throw new ArgumentNullException();

694

695

var p = new Promise<T>();

696

var p = new Promise<T>();

696

p.Reject(error);

697

p.Reject(error);

697

return p;

698

return p;

698

}

699

}

699

700

#region IPromiseBase explicit implementation

701

#region IPromiseBase explicit implementation

701

702

IPromise IPromise.Error(ErrorHandler error) {

703

IPromise IPromise.Error(ErrorHandler error) {

703

return Error(error);

704

return Error(error);

704

}

705

}

705

706

IPromise IPromise.Anyway(Action handler) {

707

IPromise IPromise.Anyway(Action handler) {

707

return Anyway(handler);

708

return Anyway(handler);

708

}

709

}

709

710

IPromise IPromise.Finally(Action handler) {

711

IPromise IPromise.Finally(Action handler) {

711

return Finally(handler);

712

return Finally(handler);

712

}

713

}

713

714

IPromise IPromise.Cancelled(Action handler) {

715

IPromise IPromise.Cancelled(Action handler) {

715

return Cancelled(handler);

716

return Cancelled(handler);

716

}

717

}

717

718

void IPromise.Join() {

719

void IPromise.Join() {

719

Join();

720

Join();

720

}

721

}

721

722

void IPromise.Join(int timeout) {

723

void IPromise.Join(int timeout) {

723

Join(timeout);

724

Join(timeout);

724

}

725

}

725

726

#endregion

727

#endregion

727

728

729

730

}

731

}

731

}

732

}

	Site-wide shortcuts
/	Use quick search box
g h	Goto home page
g g	Goto my private gists page
g G	Goto my public gists page
g 0-9	Goto bookmarked items from 0-9
n r	New repository page
n g	New gist page

	Repositories
g s	Goto summary page
g c	Goto changelog page
g f	Goto files page
g F	Goto files page with file search activated
g p	Goto pull requests page
g o	Goto repository settings
g O	Goto repository access permissions settings
t s	Toggle sidebar on some pages

             using System;
             using System.Collections.Generic;
             using System.Linq;
             using System.Text;
             namespace Implab {
                 public interface IPromise: ICancellable {
                     /// <summary>
                     /// Check whereather the promise has no more than one dependent promise.
                     /// </summary>
                     bool IsExclusive {
                         get;
                     }
                     /// <summary>
                     /// Тип результата, получаемого через данное обещание.
                     /// </summary>
                     Type PromiseType { get; }
+                    /// <summary>
+                    /// Обещание является выполненым, либо успешно, либо с ошибкой.
+                    /// </summary>
                     bool IsResolved { get; }
+                    /// <summary>
+                    /// Обещание было отменено.
+                    /// </summary>
                     bool IsCancelled { get; }
                     IPromise Then(Action success,ErrorHandler error);
                     IPromise Then(Action success);
                     IPromise Error(ErrorHandler error);
+                    /// <summary>
+                    /// Обрабатывает либо ошибку, либо результат. Событие отмены не обрабатывается.
+                    /// </summary>
+                    /// <param name="handler">Обработчик.</param>
+                    /// <remarks>После обработке ошибки, она передается дальше.</remarks>
                     IPromise Anyway(Action handler);
+                    /// <summary>
+                    /// Обрабатывает либо ошибку, либо результат, либо отмену обещания.
+                    /// </summary>
+                    /// <param name="handler">Обработчик.</param>
+                    /// <remarks>После обработке ошибки, она передается дальше.</remarks>
                     IPromise Finally(Action handler);
+                    /// <summary>
+                    /// Обработчик для регистрации отмены обещания, событие отмены не может быть подавлено.
+                    /// </summary>
+                    /// <returns>Новое обещание, связанное с текущим.</returns>
+                    /// <param name="handler">Обработчик события.</param>
+                    /// <remarks>Если обработчик вызывает исключение, то оно передается обработчику ошибки, результат работы
+                    /// которого будет передан связанному обещанию</remarks>
                     IPromise Cancelled(Action handler);
+                    /// <summary>
+                    /// Преобразует результат обещания к заданному типу и возвращает новое обещание.
+                    /// </summary>
                     IPromise<T> Cast<T>();
+                    /// <summary>
+                    /// Синхронизирует текущий поток с обещанием.
+                    /// </summary>
                     void Join();
+                    /// <summary>
+                    /// Синхронизирует текущий поток с обещанием.
+                    /// </summary>
+                    /// <param name="timeout">Время ожидания, по его истечению возникнет исключение.</param>
+                    /// <exception cref="TimeoutException">Превышено время ожидания.</exception>
                     void Join(int timeout);
                 }
             }

             using System;
             using System.Collections.Generic;
             using System.Reflection;
             using System.Diagnostics;
             using System.Threading;
             using Implab.Parallels;
             namespace Implab {
                 public delegate void ErrorHandler(Exception e);
                 public delegate T ErrorHandler<out T>(Exception e);
                 public delegate void ResultHandler<in T>(T result);
                 public delegate TNew ResultMapper<in TSrc,out TNew>(TSrc result);
                 public delegate IPromise<TNew> ChainedOperation<in TSrc,TNew>(TSrc result);
                 /// <summary>
                 /// Класс для асинхронного получения результатов. Так называемое "обещание".
                 /// </summary>
                 /// <typeparam name="T">Тип получаемого результата</typeparam>
                 /// <remarks>
                 /// <para>Сервис при обращении к его методу дает обещаиние о выполнении операции,
                 /// клиент получив такое обещание может установить ряд обратных вызово для получения
                 /// событий выполнения обещания, тоесть завершения операции и предоставлении результатов.</para>
                 /// <para>
                 /// Обещение может быть как выполнено, так и выполнено с ошибкой. Для подписки на
                 /// данные события клиент должен использовать методы <c>Then</c>.
                 /// </para>
                 /// <para>
                 /// Сервис, в свою очередь, по окончанию выполнения операции (возможно с ошибкой),
                 /// использует методы <c>Resolve</c> либо <c>Reject</c> для оповещения клиетна о
                 /// выполнении обещания.
                 /// </para>
                 /// <para>
                 /// Если сервер успел выполнить обещание еще до того, как клиент на него подписался,
                 /// то в момент подписки клиента будут вызваны соответсвующие события в синхронном
                 /// режиме и клиент будет оповещен в любом случае. Иначе, обработчики добавляются в
                 /// список в порядке подписания и в этом же порядке они будут вызваны при выполнении
                 /// обещания.
                 /// </para>
                 /// <para>
                 /// Обрабатывая результаты обещания можно преобразовывать результаты либо инициировать
                 /// связанные асинхронные операции, которые также возвращают обещания. Для этого следует
                 /// использовать соответствующую форму методе <c>Then</c>.
                 /// </para>
                 /// <para>
                 /// Также хорошим правилом является то, что <c>Resolve</c> и <c>Reject</c> должен вызывать
                 /// только инициатор обещания иначе могут возникнуть противоречия.
                 /// </para>
                 /// </remarks>
                 public class Promise<T> : IPromise<T> {
                     protected struct HandlerDescriptor {
                         public ResultHandler<T> resultHandler;
                         public ErrorHandler<T> errorHandler;
                         public Action cancellHandler;
                         public Promise<T> medium;
                         public void Resolve(T result) {
                             if (resultHandler != null) {
                                 try {
                                     resultHandler(result);
                                 } catch (Exception e) {
                                     Reject(e);
                                     return;
                                 }
                             }
                             if (medium != null)
                                 medium.Resolve(result);
                         }
                         public void Reject(Exception err) {
                             if (errorHandler != null) {
                                 try {
                                     var res = errorHandler(err);
                                     if (medium != null)
                                         medium.Resolve(res);
                                 } catch (TransientPromiseException err2) {
                                     if (medium != null)
                                         medium.Reject(err2.InnerException);
                                 } catch (Exception err2) {
                                     if (medium != null)
                                         medium.Reject(err2);
                                 }
                             } else if (medium != null)
                                 medium.Reject(err);
                         }
                         public void Cancel() {
                             if (cancellHandler != null) {
                                 try {
                                     cancellHandler();
                                 } catch (Exception err) {
                                     Reject(err);
                                     return;
                                 }
                             }
                             if (medium != null)
                                 medium.Cancel();
                         }
                     }
                     const int UNRESOLVED_SATE = 0;
                     const int TRANSITIONAL_STATE = 1;
                     const int SUCCEEDED_STATE = 2;
                     const int REJECTED_STATE = 3;
                     const int CANCELLED_STATE = 4;
                     readonly bool m_cancellable;
                     int m_childrenCount = 0;
                     int m_state;
                     T m_result;
                     Exception m_error;
                     readonly MTQueue<HandlerDescriptor> m_handlers = new MTQueue<HandlerDescriptor>();
                     public Promise() {
                         m_cancellable = true;
                     }
                     public Promise(IPromise parent, bool cancellable) {
                         m_cancellable = cancellable;
                         if (parent != null)
                             Cancelled(() => {
                                 if (parent.IsExclusive)
                                     parent.Cancel();
                             });
                     }
                     bool BeginTransit() {
                         return UNRESOLVED_SATE == Interlocked.CompareExchange(ref m_state, TRANSITIONAL_STATE, UNRESOLVED_SATE);
                     }
                     void CompleteTransit(int state) {
                         if (TRANSITIONAL_STATE != Interlocked.CompareExchange(ref m_state, state, TRANSITIONAL_STATE))
                             throw new InvalidOperationException("Can't complete transition when the object isn't in the transitional state");
                     }
                     void WaitTransition() {
                         while (m_state == TRANSITIONAL_STATE) {
                             /* noop */
                         }
                     }
                     public bool IsResolved {
                         get {
                             return m_state > 1;
                         }
                     }
                     public bool IsCancelled {
                         get {
                             return m_state == CANCELLED_STATE;
                         }
                     }
                     public Type PromiseType {
                         get { return typeof(T); }
                     }
                     /// <summary>
                     /// Выполняет обещание, сообщая об успешном выполнении.
                     /// </summary>
                     /// <param name="result">Результат выполнения.</param>
                     /// <exception cref="InvalidOperationException">Данное обещание уже выполнено</exception>
                     public void Resolve(T result) {
                         if (BeginTransit()) {
                             m_result = result;
                             CompleteTransit(SUCCEEDED_STATE);
                             OnStateChanged();
                         } else {
                             WaitTransition();
                             if (m_state != CANCELLED_STATE)
                                 throw new InvalidOperationException("The promise is already resolved");
                         }
                     }
                     /// <summary>
                     /// Выполняет обещание, сообщая об успешном выполнении. Результатом выполнения будет пустое значения.
                     /// </summary>
                     /// <remarks>
                     /// Данный вариант удобен в случаях, когда интересен факт выполнения операции, нежели полученное значение.
                     /// </remarks>
                     public void Resolve() {
                         Resolve(default(T));
                     }
                     /// <summary>
                     /// Выполняет обещание, сообщая об ошибке
                     /// </summary>
                     /// <remarks>
                     /// Поскольку обещание должно работать в многопточной среде, при его выполнении сразу несколько потоков
                     /// могу вернуть ошибку, при этом только первая будет использована в качестве результата, остальные
                     /// будут проигнорированы.
                     /// </remarks>
                     /// <param name="error">Исключение возникшее при выполнении операции</param>
                     /// <exception cref="InvalidOperationException">Данное обещание уже выполнено</exception>
                     public void Reject(Exception error) {
                         if (BeginTransit()) {
                             m_error = error;
                             CompleteTransit(REJECTED_STATE);
                             OnStateChanged();
                         } else {
                             WaitTransition();
                             if (m_state == SUCCEEDED_STATE)
                                 throw new InvalidOperationException("The promise is already resolved");
                         }
                     }
                     /// <summary>
                     /// Отменяет операцию, если это возможно.
                     /// </summary>
                     /// <returns><c>true</c> Операция была отменена, обработчики не будут вызваны.<c>false</c> отмена не возможна, поскольку обещание уже выполнено и обработчики отработали.</returns>
                     public bool Cancel() {
                         if (m_cancellable && BeginTransit()) {
                             CompleteTransit(CANCELLED_STATE);
                             OnStateChanged();
                             return true;
                         }
                         return false;
                     }
                     // сделано для возвращаемого типа void
                     protected void InternalCancel() {
                         Cancel();
                     }
                     /// <summary>
                     /// Adds new handlers to this promise.
                     /// </summary>
                     /// <param name="success">The handler of the successfully completed operation.
                     /// This handler will recieve an operation result as a parameter.</param>
                     /// <param name="error">Handles an exception that may occur during the operation and returns the value which will be used as the result of the operation.</param>
                     /// <returns>The new promise chained to this one.</returns>
                     public IPromise<T> Then(ResultHandler<T> success, ErrorHandler<T> error) {
                         if (success == null && error == null)
                             return this;
                         var medium = new Promise<T>(this, true);
                         AddHandler(success, error, null, medium);
                         return medium;
                     }
                     public IPromise Then(Action success, ErrorHandler error) {
                         return Then(
                             x => success(),
                             e => {
                                 error(e);
                                 return default(T);
                             }
                         );
                     }
                     public IPromise Then(Action success) {
                         return Then(x => success());
                     }
                     public IPromise<T> Then(ResultHandler<T> success) {
                         if (success == null)
                             return this;
                         var medium = new Promise<T>(this, true);
                         AddHandler(success, null, null, medium);
                         return medium;
                     }
                     public IPromise Error(ErrorHandler error) {
                         if (error == null)
                             return this;
                         var medium = new Promise<T>(this, true);
                         AddHandler(
                             null,
                             e => {
                                 error(e);
                                 return default(T);
                             },
                             null,
                             medium
                         );
                         return medium;
                     }
                     /// <summary>
                     /// Handles error and allows to keep the promise.
                     /// </summary>
                     /// <remarks>
                     /// If the specified handler throws an exception, this exception will be used to reject the promise.
                     /// </remarks>
                     /// <param name="handler">The error handler which returns the result of the promise.</param>
                     /// <returns>New promise.</returns>
                     public IPromise<T> Error(ErrorHandler<T> handler) {
                         if (handler == null)
                             return this;
                         var medium = new Promise<T>(this, true);
                         AddHandler(null, handler, null, medium);
                         return medium;
                     }
                     public IPromise<T> Anyway(Action handler) {
                         if (handler == null)
                             return this;
                         var medium = new Promise<T>(this, true);
                         AddHandler(
                             x => handler(),
                             e => {
                                 handler();
                                 throw new TransientPromiseException(e);
                             },
                             null,
                             medium
                         );
                         return medium;
                     }
                     /// <summary>
                     /// Позволяет преобразовать результат выполения операции к новому типу.
                     /// </summary>
                     /// <typeparam name="TNew">Новый тип результата.</typeparam>
                     /// <param name="mapper">Преобразование результата к новому типу.</param>
                     /// <param name="error">Обработчик ошибки. Данный обработчик получит
                     /// исключение возникшее при выполнении операции.</param>
                     /// <returns>Новое обещание, которое будет выполнено при выполнении исходного обещания.</returns>
                     public IPromise<TNew> Map<TNew>(ResultMapper<T, TNew> mapper, ErrorHandler<T> error) {
                         if (mapper == null)
                             throw new ArgumentNullException("mapper");
                         // создаем прицепленное обещание
                         var chained = new Promise<TNew>(this, true);
                         ResultHandler<T> resultHandler = result => chained.Resolve(mapper(result));
                         ErrorHandler<T> errorHandler;
                         if (error != null)
                             errorHandler = e => {
                                 try {
                                     return error(e);
                                 } catch (Exception e2) {
                                     // в случае ошибки нужно передать исключение дальше по цепочке
                                     chained.Reject(e2);
                                 }
                                 return default(T);
                             };
                         else
                             errorHandler = e => {
                                 chained.Reject(e);
                                 return default(T);
                             };
                         AddHandler(
                             resultHandler,
                             errorHandler,
                             chained.InternalCancel,
                             null
                         );
                         return chained;
                     }
                     public IPromise<TNew> Map<TNew>(ResultMapper<T, TNew> mapper) {
                         return Map(mapper, null);
                     }
                     /// <summary>
                     /// Сцепляет несколько аснхронных операций. Указанная асинхронная операция будет вызвана после
                     /// выполнения текущей, а результат текущей операции может быть использован для инициализации
                     /// новой операции.
                     /// </summary>
                     /// <typeparam name="TNew">Тип результата указанной асинхронной операции.</typeparam>
                     /// <param name="chained">Асинхронная операция, которая должна будет начаться после выполнения текущей.</param>
                     /// <param name="error">Обработчик ошибки. Данный обработчик получит
                     /// исключение возникшее при выполнении текуещй операции.</param>
                     /// <returns>Новое обещание, которое будет выполнено по окончанию указанной аснхронной операции.</returns>
                     public IPromise<TNew> Chain<TNew>(ChainedOperation<T, TNew> chained, ErrorHandler<T> error) {
                         // проблема в том, что на момент связывания еще не начата асинхронная операция, поэтому нужно
                         // создать посредника, к которому будут подвызяваться следующие обработчики.
                         // когда будет выполнена реальная асинхронная операция, она обратиться к посреднику, чтобы
                         // передать через него результаты работы.
                         var medium = new Promise<TNew>(this, true);
                         ResultHandler<T> resultHandler = delegate(T result) {
                             if (medium.IsCancelled)
                                 return;
                             var promise = chained(result);
                             promise.Then(
                                 medium.Resolve,
                                 err => {
                                     medium.Reject(err);
                                     throw new TransientPromiseException(err);
                                 }
                             );
                             // notify chained operation that it's not needed anymore
                             // порядок вызова Then, Cancelled важен, поскольку от этого
                             // зависит IsExclusive
                             medium.Cancelled(() => {
                                 if (promise.IsExclusive)
                                     promise.Cancel();
                             });
                             // внешняя отмена связанной операции рассматривается как ошибка
                             promise.Cancelled(() => medium.Reject(new OperationCanceledException()));
                         };
                         ErrorHandler<T> errorHandler = delegate(Exception e) {
                             if (error != null) {
                                 try {
                                     return error(e);
                                 } catch (Exception e2) {
                                     medium.Reject(e2);
                                     return default(T);
                                 }
                             }
                             // в случае ошибки нужно передать исключение дальше по цепочке
                             medium.Reject(e);
                             return default(T);
                         };
                         AddHandler(
                             resultHandler,
                             errorHandler,
                             medium.InternalCancel,
                             null
                         );
                         return medium;
                     }
                     public IPromise<TNew> Chain<TNew>(ChainedOperation<T, TNew> chained) {
                         return Chain(chained, null);
                     }
                     public IPromise<T> Cancelled(Action handler) {
-                        AddHandler(null, null, handler, null);
+                        var medium = new Promise<T>(this, true);
-                        return this;
+                        AddHandler(null, null, handler, medium);
+                        return medium;
                     }
                     /// <summary>
                     /// Adds the specified handler for all cases (success, error, cancel)
                     /// </summary>
                     /// <param name="handler">The handler that will be called anyway</param>
                     /// <returns>self</returns>
                     public IPromise<T> Finally(Action handler) {
                         if (handler == null)
                             throw new ArgumentNullException("handler");
                         AddHandler(
                             x => handler(),
                             e => {
                                 handler();
                                 throw new TransientPromiseException(e);
                             },
                             handler,
                             null
                         );
                         return this;
                     }
                     /// <summary>
                     /// Преобразует результат обещания к нужному типу
                     /// </summary>
                     /// <typeparam name="T2"></typeparam>
                     /// <returns></returns>
                     public IPromise<T2> Cast<T2>() {
                         return Map(x => (T2)(object)x, null);
                     }
                     /// <summary>
                     /// Дожидается отложенного обещания и в случае успеха, возвращает
                     /// его, результат, в противном случае бросает исключение.
                     /// </summary>
                     /// <remarks>
                     /// <para>
                     /// Если ожидание обещания было прервано по таймауту, это не значит,
                     /// что обещание было отменено или что-то в этом роде, это только
                     /// означает, что мы его не дождались, однако все зарегистрированные
                     /// обработчики, как были так остались и они будут вызваны, когда
                     /// обещание будет выполнено.
                     /// </para>
                     /// <para>
                     /// Такое поведение вполне оправдано поскольку таймаут может истечь
                     /// в тот момент, когда началась обработка цепочки обработчиков, и
                     /// к тому же текущее обещание может стоять в цепочке обещаний и его
                     /// отклонение может привести к непрогнозируемому результату.
                     /// </para>
                     /// </remarks>
                     /// <param name="timeout">Время ожидания</param>
                     /// <returns>Результат выполнения обещания</returns>
                     public T Join(int timeout) {
                         var evt = new ManualResetEvent(false);
                         Anyway(() => evt.Set());
                         Cancelled(() => evt.Set());
                         if (!evt.WaitOne(timeout, true))
                             throw new TimeoutException();
                         switch (m_state) {
                             case SUCCEEDED_STATE:
                                 return m_result;
                             case CANCELLED_STATE:
                                 throw new OperationCanceledException();
                             case REJECTED_STATE:
                                 throw new TargetInvocationException(m_error);
                             default:
                                 throw new ApplicationException(String.Format("Invalid promise state {0}", m_state));
                         }
                     }
                     public T Join() {
                         return Join(Timeout.Infinite);
                     }
                     void AddHandler(ResultHandler<T> success, ErrorHandler<T> error, Action cancel, Promise<T> medium) {
                         if (success != null || error != null)
                             Interlocked.Increment(ref m_childrenCount);
                         var handler = new HandlerDescriptor {
                             resultHandler = success,
                             errorHandler = error,
                             cancellHandler = cancel,
                             medium = medium
                         };
                         bool queued;
                         if (!IsResolved) {
                             m_handlers.Enqueue(handler);
                             queued = true;
                         } else {
                             // the promise is in resolved state, just invoke the handled with minimum overhead
                             queued = false;
                             InvokeHandler(handler);
                         }
                         if (queued && IsResolved && m_handlers.TryDequeue(out handler))
                             // if the promise have been resolved while we was adding handler to the queue
                             // we can't guarantee that someone is still processing it
                             // therefore we will fetch a handler from the queue and execute it
                             // note that fetched handler may be not the one that we have added
                             // even we can fetch no handlers at all :)
                             InvokeHandler(handler);
                     }
                     protected virtual void InvokeHandler(HandlerDescriptor handler) {
                         switch (m_state) {
                             case SUCCEEDED_STATE:
                                 handler.Resolve(m_result);
                                 break;
                             case REJECTED_STATE:
                                 handler.Reject(m_error);
                                 break;
                             case CANCELLED_STATE:
                                 handler.Cancel();
                                 break;
                             default:
                                 // do nothing
                                 return;
                         }
                     }
                     void OnStateChanged() {
                         HandlerDescriptor handler;
                         while (m_handlers.TryDequeue(out handler))
                             InvokeHandler(handler);
                     }
                     public bool IsExclusive {
                         get {
                             return m_childrenCount <= 1;
                         }
                     }
                     /// <summary>
                     /// Объединяет несколько обещаний в одно, результатом которого является массив результатов других обещаний.
                     /// Если хотябы одно из переданных обещаний не будет выполнено, то новое обещение тоже не будет выполнено.
                     /// При отмене нового обещания, переданные обещания также будут отменены, если никто больше на них не подписан.
                     /// </summary>
                     /// <param name="promises">Список обещаний. Если список пустой, то результирующее обещание возвращается уже выполненным.</param>
                     /// <returns>Обещание объединяющее в себе результат переданных обещаний.</returns>
                     /// <exception cref="ArgumentNullException"><paramref name="promises"/> не может быть null</exception>
                     public static IPromise<T[]> CreateComposite(IList<IPromise<T>> promises) {
                         if (promises == null)
                             throw new ArgumentNullException();
                         // создаем аккумулятор для результатов и результирующее обещание
                         var result = new T[promises.Count];
                         var promise = new Promise<T[]>();
                         // special case
                         if (promises.Count == 0) {
                             promise.Resolve(result);
                             return promise;
                         }
                         int pending = promises.Count;
                         for (int i = 0; i < promises.Count; i++) {
                             var dest = i;
                             if (promises[i] != null) {
                                 promises[i].Then(
                                     x => {
                                         result[dest] = x;
                                         if (Interlocked.Decrement(ref pending) == 0)
                                             promise.Resolve(result);
                                     },
                                     e => {
                                         promise.Reject(e);
                                         return default(T);
                                     }
                                 );
                             } else {
                                 if (Interlocked.Decrement(ref pending) == 0)
                                     promise.Resolve(result);
                             }
                         }
                         promise.Cancelled(
                             () => {
                                 foreach (var d in promises)
                                     if (d != null && d.IsExclusive)
                                         d.Cancel();
                             }
                         );
                         return promise;
                     }
                     /// <summary>
                     /// Объединяет несколько обещаний в одно. Результирующее обещание будет выполнено при
                     /// выполнении всех указанных обещаний. При этом возвращаемые значения первичных обещаний
                     /// игнорируются.
                     /// </summary>
                     /// <param name="promises">Коллекция первичных обещаний, которые будут объеденены в одно.</param>
                     /// <returns>Новое обещание, объединяющее в себе переданные.</returns>
                     /// <remarks>
                     /// Если в коллекции встречаюься <c>null</c>, то они воспринимаются как выполненные обещания.
                     /// </remarks>
                     public static IPromise CreateComposite(ICollection<IPromise> promises) {
                         if (promises == null)
                             throw new ArgumentNullException();
                         if (promises.Count == 0)
                             return Promise<object>.ResultToPromise(null);
                         int countdown = promises.Count;
                         var result = new Promise<object>();
                         foreach (var d in promises) {
                             if (d == null) {
                                 if (Interlocked.Decrement(ref countdown) == 0)
                                     result.Resolve(null);
                             } else {
                                 d.Then(() => {
                                     if (Interlocked.Decrement(ref countdown) == 0)
                                         result.Resolve(null);
                                 });
                             }
                         }
                         result.Cancelled(() => {
                             foreach (var d in promises)
                                 if (d != null && d.IsExclusive)
                                     d.Cancel();
                         });
                         return result;
                     }
                     public static Promise<T> ResultToPromise(T result) {
                         var p = new Promise<T>();
                         p.Resolve(result);
                         return p;
                     }
                     public static Promise<T> ExceptionToPromise(Exception error) {
                         if (error == null)
                             throw new ArgumentNullException();
                         var p = new Promise<T>();
                         p.Reject(error);
                         return p;
                     }
                     #region IPromiseBase explicit implementation
                     IPromise IPromise.Error(ErrorHandler error) {
                         return Error(error);
                     }
                     IPromise IPromise.Anyway(Action handler) {
                         return Anyway(handler);
                     }
                     IPromise IPromise.Finally(Action handler) {
                         return Finally(handler);
                     }
                     IPromise IPromise.Cancelled(Action handler) {
                         return Cancelled(handler);
                     }
                     void IPromise.Join() {
                         Join();
                     }
                     void IPromise.Join(int timeout) {
                         Join(timeout);
                     }
                     #endregion
                 }
             }