// OpenTween - Client of Twitter
// Copyright (c) 2023 kim_upsilon (@kim_upsilon)
// All rights reserved.
//
// This file is part of OpenTween.
//
// This program is free software; you can redistribute it and/or modify it
// under the terms of the GNU General Public License as published by the Free
// Software Foundation; either version 3 of the License, or (at your option)
// any later version.
//
// This program is distributed in the hope that it will be useful, but
// WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
// or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
// for more details.
//
// You should have received a copy of the GNU General Public License along
// with this program. If not, see , or write to
// the Free Software Foundation, Inc., 51 Franklin Street - Fifth Floor,
// Boston, MA 02110-1301, USA.
#nullable enable
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
namespace OpenTween
{
public class TaskCollection
{
private readonly List> taskFuncs;
private Func ignoreExceptionFunc = _ => true;
public TaskCollection()
=> this.taskFuncs = new();
public TaskCollection(int capacity)
=> this.taskFuncs = new(capacity);
public void Add(Func func)
=> this.taskFuncs.Add(func);
public void Add(IEnumerable> tasks)
=> this.taskFuncs.AddRange(tasks);
public TaskCollection IgnoreException(Func condition)
{
this.ignoreExceptionFunc = condition;
return this;
}
public Task RunAll()
=> this.RunAll(runOnThreadPool: false);
public Task RunAll(bool runOnThreadPool)
=> Task.WhenAll(this.taskFuncs.Select(x => this.WrapAsyncFunc(x, runOnThreadPool)));
private Task WrapAsyncFunc(Func func, bool runOnThreadPool)
{
Task WrappedFunc()
=> AsyncExceptionBoundary.Wrap(func, this.ignoreExceptionFunc);
if (runOnThreadPool)
return Task.Run(WrappedFunc);
else
return WrappedFunc();
}
}
}