harmonyos实现的VideoPlayerManager功能，一个旨在帮助控制player类的项目

package com.volokh.video_player_manager.ui; import com.volokh.video_player_manager.Config; import com.volokh.video_player_manager.utils.Logger; import ohos.agp.components.AttrSet; import ohos.agp.graphics.SurfaceOps; import ohos.agp.graphics.TextureHolder; import ohos.app.Context; import ohos.app.dispatcher.task.TaskPriority; import ohos.data.DatabaseHelper; import ohos.data.preferences.Preferences; import ohos.eventhandler.EventRunner; import ohos.global.resource.RawFileDescriptor; import ohos.media.player.Player; import java.io.IOException; import java.util.ArrayList; import java.util.HashSet; import java.util.List; import java.util.Set; /** * This is player implementation based on {@link ohos.agp.components.surfaceprovider.SurfaceProvider} * It encapsulates {@link Player}. * <p> * It ensures that MediaPlayer methods are called from not main thread. * MediaPlayer methods are directly connected with hardware. That's why they should not be called from UI thread * * @author danylo.ohos */ public class VideoPlayerView extends ScalableTextureView implements TextureView.SurfaceTextureListener, MediaPlayerWrapper.MainThreadMediaPlayerListener, MediaPlayerWrapper.VideoStateListener { private static final boolean SHOW_LOGS = Config.SHOW_LOGS; private String TAG = VideoPlayerView.class.getSimpleName(); private static final String IS_VIDEO_MUTED = "IS_VIDEO_MUTED"; // private HandlerThreadExtension mViewHandlerBackgroundThread; /** * A Listener that propagates {@link Player} listeners is background thread. * Probably call of this listener should also need to be synchronized with it creation and destroy places. */ private BackgroundThreadMediaPlayerListener mMediaPlayerListenerBackgroundThread; private MediaPlayerWrapper.VideoStateListener mVideoStateListener; // private SurfaceTextureListener mLocalSurfaceTextureListener; private RawFileDescriptor mAssetFileDescriptor; private String mPath; private Context mContext; private final ReadyForPlaybackIndicator mReadyForPlaybackIndicator = new ReadyForPlaybackIndicator(); private final Set<MediaPlayerWrapper.MainThreadMediaPlayerListener> mMediaPlayerMainThreadListeners = new HashSet<>(); private SurfaceOps surfaceOps; public MediaPlayerWrapper.State getCurrentState() { synchronized (mReadyForPlaybackIndicator) { return mMediaPlayer.getCurrentState(); } } public RawFileDescriptor getAssetFileDescriptorDataSource() { return mAssetFileDescriptor; } public String getVideoUrlDataSource() { return mPath; } public interface BackgroundThreadMediaPlayerListener { void onVideoSizeChangedBackgroundThread(int width, int height); void onVideoPreparedBackgroundThread(); void onVideoCompletionBackgroundThread(); void onErrorBackgroundThread(int what, int extra); } public VideoPlayerView(Context context) { super(context); mContext = context; initView(); } public VideoPlayerView(Context context, AttrSet attrs) { super(context, attrs); Logger.err(TAG + " context = " + context, ""); mContext = context; initView(); } /* public VideoPlayerView(Context context, Attr attrs, int defStyleAttr) { super(context, attrs, defStyleAttr); initView(); }*/ /* @TargetApi(Build.VERSION_CODES.LOLLIPOP) public VideoPlayerView(Context context, AttrSet attrs, int defStyleAttr, int defStyleRes) { super(context, attrs, defStyleAttr, defStyleRes); initView(); } */ private void checkThread() { if (EventRunner.current() == EventRunner.getMainEventRunner()) { throw new RuntimeException("cannot be in main thread"); } } public void reset() { checkThread(); synchronized (mReadyForPlaybackIndicator) { mMediaPlayer.reset(); } } public void release() { checkThread(); synchronized (mReadyForPlaybackIndicator) { mMediaPlayer.release(); } } public void clearPlayerInstance() { if (SHOW_LOGS) Logger.v(TAG, ">> clearPlayerInstance"); checkThread(); synchronized (mReadyForPlaybackIndicator) { mReadyForPlaybackIndicator.setVideoSize(null, null); mMediaPlayer.clearAll(); mMediaPlayer = null; } if (SHOW_LOGS) Logger.v(TAG, "<< clearPlayerInstance"); } public void createNewPlayerInstance() { if (SHOW_LOGS) Logger.v(TAG, ">> createNewPlayerInstance"); if (SHOW_LOGS) Logger.v(TAG, "createNewPlayerInstance main Looper " + EventRunner.getMainEventRunner()); if (SHOW_LOGS) Logger.v(TAG, "createNewPlayerInstance my Looper " + EventRunner.current()); checkThread(); synchronized (mReadyForPlaybackIndicator) { //创建Player mMediaPlayer = new MediaPlayerWrapperImpl(getContext()); // 设置时评宽和高 mReadyForPlaybackIndicator.setVideoSize(null, null); mReadyForPlaybackIndicator.setFailedToPrepareUiForPlayback(false); Logger.v(TAG, "isSurfaceTextureAvailable =" + mReadyForPlaybackIndicator.isSurfaceTextureAvailable()); mMediaPlayer.setMainThreadMediaPlayerListener(this); mMediaPlayer.setVideoStateListener(this); } if (SHOW_LOGS) Logger.v(TAG, "<< createNewPlayerInstance"); } public void prepare() { checkThread(); synchronized (mReadyForPlaybackIndicator) { mMediaPlayer.prepare(); } } public void stop() { checkThread(); synchronized (mReadyForPlaybackIndicator) { mMediaPlayer.stop(); } } private void notifyOnVideoStopped() { if (SHOW_LOGS) Logger.v(TAG, "notifyOnVideoStopped"); List<MediaPlayerWrapper.MainThreadMediaPlayerListener> listCopy; synchronized (mMediaPlayerMainThreadListeners) { listCopy = new ArrayList<>(mMediaPlayerMainThreadListeners); } for (MediaPlayerWrapper.MainThreadMediaPlayerListener listener : listCopy) { listener.onVideoStoppedMainThread(); } } private boolean isVideoSizeAvailable() { boolean isVideoSizeAvailable = getContentHeight() != null && getContentWidth() != null; if (SHOW_LOGS) Logger.v(TAG, "isVideoSizeAvailable " + isVideoSizeAvailable); return isVideoSizeAvailable; } public void start() { if (SHOW_LOGS) Logger.v(TAG, ">> start"); synchronized (mReadyForPlaybackIndicator) { if (mReadyForPlaybackIndicator.isReadyForPlayback()) { mMediaPlayer.start(); } else { if (SHOW_LOGS) Logger.v(TAG, "start, >> wait"); if (!mReadyForPlaybackIndicator.isFailedToPrepareUiForPlayback()) { try { mReadyForPlaybackIndicator.wait(); } catch (InterruptedException e) { throw new RuntimeException(e); } if (SHOW_LOGS) Logger.v(TAG, "start, << wait"); if (mReadyForPlaybackIndicator.isReadyForPlayback()) { mMediaPlayer.start(); } else { if (SHOW_LOGS) Logger.w(TAG, "start, movie is not ready, Player become STARTED state, but it will actually don't play"); } } else { if (SHOW_LOGS) Logger.w(TAG, "start, movie is not ready. Video size will not become available"); } } } if (SHOW_LOGS) Logger.v(TAG, "<< start"); } private void initView() { TAG = "" + this; if (SHOW_LOGS) Logger.v(TAG, "initV