Oberserver

观察者模式

观察者模式在我司SDK中也被大量使用，而且我发现其实大家是没有区分observer和vistor的差异 把observer当vistor用。

observer主要建立了一种通知依赖关系，当对象A的状态发生改变的时候，需要通知到B 如果这样的依赖过于紧密，整体的构架就比较死板。比较难复用

观察者模式的好处就是目标发送通知的时候，不用去指定一个具体的观察者，通知会自动传播 观察者自己决定是不是需要订阅通知。目标对象对这个其实是一无所知的

对于UI框架来说，这个可能见的更多,因此以进度条为例

class AppendFile{
 public:
  string file_path_;
  std::unique_ptr<ProgressBar> bar_;
  AppendFile(const string& file_name, ProgressBar* bar):
  file_path_(file_name) {
    bar_.reset(bar);
  }

  void Append() {
    // 写文件
    vector<string> truck;
    for(int i = 0;i < trunk.size();i++) {
      append(...);
      progress = (i + 1) / trunk.size();
      bar_->Set(progress);
    }
  }

};


class UI {
public:
  ProgressBar bar_;

  void Save() {
    file_path = ...;
    AppendFile file;
    file.Append()
  }
};

如果Save有更多的操作逻辑， 就得一个个的实现。然后在save里疯狂加增加的逻辑。

考虑使用observer

// 具体触发事件执行的抽象， obeserver
class IProgress{
public:
	virtual void DoProgress(float value)=0;
	virtual ~IProgress(){}
};


// observerable的类
class FileSplitter
{
	string m_filePath;
	int m_fileNumber;

	List<IProgress*>  m_iprogressList; // 抽象通知机制，支持多个观察者
	
public:
	FileSplitter(const string& filePath, int fileNumber) :
		m_filePath(filePath), 
		m_fileNumber(fileNumber){

	}

	void split(){

		//1.读取大文件

		//2.分批次向小文件中写入
		for (int i = 0; i < m_fileNumber; i++){
			//...

			float progressValue = m_fileNumber;
			progressValue = (i + 1) / progressValue;
			onProgress(progressValue);//发送通知
		}

	}


	void addIProgress(IProgress* iprogress){
		m_iprogressList.push_back(iprogress);
	}

	void removeIProgress(IProgress* iprogress){
		m_iprogressList.remove(iprogress);
	}


protected:
	virtual void onProgress(float value){
		
		List<IProgress*>::iterator itor=m_iprogressList.begin();

		while (itor != m_iprogressList.end() )
			(*itor)->DoProgress(value); //更新进度条
			itor++;
		}
	}
};

这种情况下，obeserver只需要去继承Iprogress，实现自己的观察执行逻辑，并在observable上 设置observer就可以订阅多个观察者。其实我更喜欢用函数回调的方式去做观察者。直接注入 callback就可以完成同样的能力，只需要定义出回调的std::function接口就行。

class MainForm : public Form, public IProgress
{
	TextBox* txtFilePath;
	TextBox* txtFileNumber;

	ProgressBar* progressBar;

public:
	void Button1_Click(){

		string filePath = txtFilePath->getText();
		int number = atoi(txtFileNumber->getText().c_str());

		ConsoleNotifier cn;

		FileSplitter splitter(filePath, number);

		splitter.addIProgress(this); //订阅通知
		splitter.addIProgress(&cn)； //订阅通知

		splitter.split();

		splitter.removeIProgress(this);

	}

	virtual void DoProgress(float value){
		progressBar->setValue(value);
	}
};

class ConsoleNotifier : public IProgress {
public:
	virtual void DoProgress(float value){
		cout << ".";
	}
};