#ifndef igs_maxmin_multithread_h
#define igs_maxmin_multithread_h

#include "igs_ifx_common.h" /* igs::image::rgba */
#include "igs_resource_multithread.h"
#include "igs_maxmin_slrender.h"

namespace igs
{
namespace maxmin
{
template <class IT, class RT>
class thread : public igs::resource::thread_execute_interface
{ /* thread単位の実行設定 */
public:
	thread() {}
	void setup(
		/* 入出力画像 */
		const IT *inn, IT *out, int height, int width, int channels

		/* Pixel毎に効果の強弱 */
		,
		const RT *ref /* 求める画像(out)と同じ高、幅、チャンネル数 */
		,
		const int ref_mode /* 0=R,1=G,2=B,3=A,4=Luminance,5=Nothing */

		/* Action Geometry */
		,
		int y_begin, int y_end, std::vector<int> *lens_offsets_p, std::vector<int> *lens_sizes_p, std::vector<std::vector<double>> *lens_ratio_p

		,
		double radius, double smooth_outer_range, int polygon_number, double roll_degree

		/* Action Type */
		,
		bool min_sw, bool alpha_rendering_sw, bool add_blend_sw)
	{
		this->inn_ = inn;
		this->out_ = out;
		this->height_ = height;
		this->width_ = width;
		this->channels_ = channels;

		this->ref_ = ref;
		this->ref_mode_ = ref_mode;

		this->y_begin_ = y_begin;
		this->y_end_ = y_end;
		this->lens_offsets_p_ = lens_offsets_p;
		this->lens_sizes_p_ = lens_sizes_p;
		this->lens_ratio_p_ = lens_ratio_p;

		this->radius_ = radius;
		this->smooth_outer_range_ = smooth_outer_range;
		this->polygon_number_ = polygon_number;
		this->roll_degree_ = roll_degree;

		this->min_sw_ = min_sw;
		this->alpha_rendering_sw_ = alpha_rendering_sw;
		this->add_blend_sw_ = add_blend_sw;

		igs::maxmin::slrender::resize(
			static_cast<int>(this->lens_offsets_p_->size()), this->width_, (ref != 0 || 4 <= channels) ? true : false, this->pixe_tracks_, this->alpha_ref_, this->result_);
	}
	void run(void)
	{ /* threadで実行する部分 */
		bool rgb_ren_sw = true;
		bool alp_ren_sw = this->alpha_rendering_sw_;
		bool add_ble_sw = this->add_blend_sw_;

		/* 小さいすぎて処理しない */
		if (this->pixe_tracks_.size() <= 1) {
			rgb_ren_sw = false;
			alp_ren_sw = false;
		} // not render,then copy

		/* first scanline-->next scanlineで処理するので
		かならすchannel毎にまとめてループする */

		if (igs::image::rgba::siz == this->channels_) {
			using namespace igs::image::rgba;

			for (int yy = this->y_begin_; yy <= this->y_end_; ++yy) {
				this->rendering_sl_ch_(yy, alp, alp_ren_sw, false);
			}

			for (int yy = this->y_begin_; yy <= this->y_end_; ++yy) {
				this->rendering_sl_ch_(yy, blu, rgb_ren_sw, add_ble_sw);
			}
			for (int yy = this->y_begin_; yy <= this->y_end_; ++yy) {
				this->rendering_sl_ch_(yy, gre, rgb_ren_sw, add_ble_sw);
			}
			for (int yy = this->y_begin_; yy <= this->y_end_; ++yy) {
				this->rendering_sl_ch_(yy, red, rgb_ren_sw, add_ble_sw);
			}
		} else if (igs::image::rgb::siz == this->channels_) {
			using namespace igs::image::rgb;
			for (int yy = this->y_begin_; yy <= this->y_end_; ++yy) {
				this->rendering_sl_ch_(yy, blu, rgb_ren_sw, add_ble_sw);
			}
			for (int yy = this->y_begin_; yy <= this->y_end_; ++yy) {
				this->rendering_sl_ch_(yy, gre, rgb_ren_sw, add_ble_sw);
			}
			for (int yy = this->y_begin_; yy <= this->y_end_; ++yy) {
				this->rendering_sl_ch_(yy, red, rgb_ren_sw, add_ble_sw);
			}
		} else if (1 == this->channels_) { /* grayscale */
			for (int yy = this->y_begin_; yy <= this->y_end_; ++yy) {
				this->rendering_sl_ch_(yy, 0, rgb_ren_sw, add_ble_sw);
			}
		}
	}
	void clear(void)
	{
		igs::maxmin::slrender::clear(
			this->pixe_tracks_,
			this->alpha_ref_,
			this->result_);
	}

private:
	const IT *inn_;
	IT *out_;
	int height_;
	int width_;
	int channels_;

	const RT *ref_;
	int ref_mode_;

	int y_begin_;
	int y_end_;

	std::vector<int> *lens_offsets_p_;
	std::vector<int> *lens_sizes_p_;
	std::vector<std::vector<double>> *lens_ratio_p_;

	double radius_;
	double smooth_outer_range_;
	int polygon_number_;
	double roll_degree_;

	bool min_sw_;
	bool alpha_rendering_sw_;
	bool add_blend_sw_;

	std::vector<std::vector<double>> pixe_tracks_;
	std::vector<double> alpha_ref_;
	std::vector<double> result_;

	void rendering_sl_ch_(
		const int yy, const int zz, const bool render_sw, const bool add_blend_sw)
	{
		if (!render_sw) {
			igs::maxmin::getput::copy(
				this->inn_, this->height_, this->width_, this->channels_, yy, zz, this->out_);
			return;
		}
		if (yy == this->y_begin_) {
			igs::maxmin::getput::get_first(
				this->inn_, this->out_, this->height_, this->width_, this->channels_, this->ref_, this->ref_mode_, yy, zz, static_cast<int>(this->pixe_tracks_.size() / 2), add_blend_sw, this->pixe_tracks_, this->alpha_ref_, this->result_);
		} else {
			igs::maxmin::slrender::shift(this->pixe_tracks_);
			igs::maxmin::getput::get_next(
				this->inn_, this->out_, this->height_, this->width_, this->channels_, this->ref_, this->ref_mode_, yy, zz, static_cast<int>(this->pixe_tracks_.size() / 2), add_blend_sw, this->pixe_tracks_, this->alpha_ref_, this->result_);
		}
		igs::maxmin::slrender::render(
			this->radius_, this->smooth_outer_range_, this->polygon_number_, this->roll_degree_, this->min_sw_, *(this->lens_offsets_p_), *(this->lens_sizes_p_), *(this->lens_ratio_p_), this->pixe_tracks_, this->alpha_ref_, this->result_);

		igs::maxmin::getput::put(
			this->result_, this->height_, this->width_, this->channels_, yy, zz, this->out_);
	}
};
}
}

//------------------------------------------------------------

#include "igs_maxmin_lens_matrix.h"

namespace igs
{
namespace maxmin
{
template <class IT, class RT>
class multithread
{
public:
	multithread(
		/* 入出力画像 */
		const IT *inn, IT *out, const int height, const int width, const int channels

		/* Pixel毎に効果の強弱 */
		,
		const RT *ref /* 求める画像(out)と同じ高、幅、チャンネル数 */
		,
		const int ref_mode /* 0=R,1=G,2=B,3=A,4=Luminance,5=Nothing */

		/* Action Geometry */
		,
		const double radius /* =1.0  0..100...DOUBLE_MAX */
		,
		const double smooth_outer_range /*=1.0  0..100...DOUBLE_MAX */
		,
		const int polygon_number /* =2    2...16...INT_MAX */
		,
		const double roll_degree /* =0.0  0...360...DOUBLE_MAX */

		/* Action Type */
		,
		const bool min_sw /* =false */
		,
		const bool alpha_rendering_sw /* =true */
		,
		const bool add_blend_sw /* =false */

		/* Speed up */
		,
		const int number_of_thread /* =1    1...24...INT_MAX */
		)
	{
		/*--------------メモリ確保--------------------------*/
		igs::maxmin::alloc_and_shape_lens_matrix(
			radius, radius + smooth_outer_range, polygon_number, roll_degree, this->lens_offsets_, this->lens_sizes_, this->lens_ratio_);
		/*-------スレッド毎の処理指定-----------------------*/
		int thread_num = number_of_thread;
		/* ゼロ以下の場合強制変更。そもそもGUIでエラーにすべき */
		if (thread_num < 1) {
			thread_num = 1;
		}
		/* 高さより多い場合強制変更。そもそもGUIでエラーにすべき */
		if (height < thread_num) {
			thread_num = height;
		}
		/* threadメモリ確保 */
		this->threads_.resize(thread_num);
		/* thread set */
		int yy = 0;
		for (int ii = 0; ii < thread_num; ++ii) {
			const int y_end = static_cast<int>(
								  static_cast<double>(height) * (ii + 1) / thread_num + 0.999999) -
							  1;
			this->threads_.at(ii).setup(
				inn, out, height, width, channels, ref, ref_mode, yy, y_end, &(this->lens_offsets_), &(this->lens_sizes_), &(this->lens_ratio_)

																															   ,
				radius, smooth_outer_range, polygon_number, roll_degree

				,
				min_sw, alpha_rendering_sw, add_blend_sw);
			yy = y_end;
		}
		/*------スレッド毎のスレッド指定------*/
		for (int ii = 0; ii < thread_num; ++ii) {
			this->mthread_.add(&(this->threads_.at(ii)));
		}
	}
	void run(void)
	{
		this->mthread_.run();
	}
	void clear()
	{
		this->mthread_.clear();
		this->threads_.clear();
		this->lens_ratio_.clear();
		this->lens_sizes_.clear();
		this->lens_offsets_.clear();
	}

private:
	std::vector<int> lens_offsets_;
	std::vector<int> lens_sizes_;
	std::vector<std::vector<double>> lens_ratio_;

	std::vector<igs::maxmin::thread<IT, RT>> threads_;
	igs::resource::multithread mthread_;
};
}
}

#endif /* !igs_maxmin_multithread_h */